Uses of Class
org.springframework.kafka.requestreply.RequestReplyFuture

Packages that use RequestReplyFuture

Package	Description
org.springframework.kafka.requestreply	Provides classes for request/reply semantics.

Uses of RequestReplyFuture in org.springframework.kafka.requestreply

Methods in org.springframework.kafka.requestreply that return RequestReplyFuture

Modifier and Type	Method	Description
RequestReplyFuture<K,V,R>	ReplyingKafkaOperations.sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)	Send a request and receive a reply with the default timeout.
RequestReplyFuture<K,V,R>	ReplyingKafkaOperations.sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, Duration replyTimeout)	Send a request and receive a reply.
RequestReplyFuture<K,V,R>	ReplyingKafkaTemplate.sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
RequestReplyFuture<K,V,R>	ReplyingKafkaTemplate.sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, Duration replyTimeout)

Methods in org.springframework.kafka.requestreply with parameters of type RequestReplyFuture

Modifier and Type	Method	Description
protected boolean	AggregatingReplyingKafkaTemplate.handleTimeout(CorrelationKey correlationId, RequestReplyFuture<K,V,Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>> future)
protected boolean	ReplyingKafkaTemplate.handleTimeout(CorrelationKey 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.