See: Description
| Interface | Description |
|---|---|
| ReplyingKafkaOperations<K,V,R> |
Request/reply operations.
|
| Class | Description |
|---|---|
| CorrelationKey |
Wrapper for byte[] that can be used as a hash key.
|
| ReplyingKafkaTemplate<K,V,R> |
A KafkaTemplate that implements request/reply semantics.
|
| ReplyingKafkaTemplate.TemplateRequestReplyFuture<K,V,R> |
A listenable future for requests/replies.
|
| RequestReplyFuture<K,V,R> |
A listenable future for requests/replies.
|