Package org.springframework.kafka.requestreply

Provides classes for request/reply semantics.

See: Description

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.

Exception Summary

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

Package org.springframework.kafka.requestreply Description

Provides classes for request/reply semantics.