Package org.springframework.kafka.requestreply

Provides classes for request/reply semantics.

Interface Summary

Interface	Description
ReplyingKafkaOperations<K,V,R>	Request/reply operations.

Class Summary

Class	Description
AggregatingReplyingKafkaTemplate<K,V,R>	A replying template that aggregates multiple replies with the same correlation id.
CorrelationKey	Wrapper for byte[] that can be used as a hash key.
ReplyingKafkaTemplate<K,V,R>	A KafkaTemplate that implements request/reply semantics.
RequestReplyFuture<K,V,R>	A listenable future for requests/replies.
RequestReplyMessageFuture<K,V>	A listenable future for Message replies.
RequestReplyTypedMessageFuture<K,V,P>	A listenable future for Message replies with a specific payload type.

Exception Summary

Exception	Description
KafkaReplyTimeoutException	Exception when a reply is not received within a timeout.