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. CorrelationKeyWrapper 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 KafkaReplyTimeoutExceptionException when a reply is not received within a timeout.