- 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>>
- Direct Known Subclasses:
- ReplyingKafkaTemplate.TemplateRequestReplyFuture
public class RequestReplyFuture<K,V,R>
extends org.springframework.util.concurrent.SettableListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
A listenable future for requests/replies.
- Since:
- 2.1.3
- Author:
- Gary Russell