Uses of Class
org.springframework.kafka.requestreply.RequestReplyFuture
Package
Description
Provides classes for request/reply semantics.
-
Uses of RequestReplyFuture in org.springframework.kafka.requestreply
Modifier and TypeMethodDescriptionReplyingKafkaOperations.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record) Send a request and receive a reply with the default timeout.ReplyingKafkaOperations.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record, Duration replyTimeout) Send a request and receive a reply.ReplyingKafkaTemplate.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record) ReplyingKafkaTemplate.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record, Duration replyTimeout) Modifier and TypeMethodDescriptionprotected boolean
AggregatingReplyingKafkaTemplate.handleTimeout
(Object correlationId, RequestReplyFuture<K, V, Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> future) protected boolean
ReplyingKafkaTemplate.handleTimeout
(Object correlationId, RequestReplyFuture<K, V, R> future) Used to inform subclasses that a request has timed out so they can clean up state and, optionally, complete the future.