Package org.springframework.kafka.requestreply

package org.springframework.kafka.requestreply

Provides classes for request/reply semantics.

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka

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.
KafkaReplyTimeoutException	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 CompletableFuture 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.