- Type Parameters:
K
- the key type.
V
- the outbound data type.
R
- the reply data type.
- All Implemented Interfaces:
- java.util.concurrent.Future<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>, org.springframework.util.concurrent.ListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
- Enclosing class:
- ReplyingKafkaTemplate<K,V,R>
public static class ReplyingKafkaTemplate.TemplateRequestReplyFuture<K,V,R>
extends RequestReplyFuture<K,V,R>
A listenable future for requests/replies.