See: Description
| Interface | Description |
|---|---|
| ReplyingKafkaOperations<K,V,R> |
Request/reply operations.
|
| 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 | Description |
|---|---|
| KafkaReplyTimeoutException |
Exception when a reply is not received within a timeout.
|