Provides classes for request/reply semantics.
ClassDescriptionA replying template that aggregates multiple replies with the same correlation id.Wrapper for byte that can be used as a hash key.Exception when a reply is not received within a timeout.ReplyingKafkaOperations<K,
V, R>Request/reply operations.ReplyingKafkaTemplate<K, V, R>A KafkaTemplate that implements request/reply semantics.RequestReplyFuture<K, V, R>A
CompletableFuturefor requests/replies.A listenable future for
Messagereplies.A listenable future for
Messagereplies with a specific payload type.