Interface ReplyingKafkaOperations<K,V,R>
-
- Type Parameters:
K
- the key type.V
- the outbound data type.R
- the reply data type.
- All Known Implementing Classes:
AggregatingReplyingKafkaTemplate
,ReplyingKafkaTemplate
public interface ReplyingKafkaOperations<K,V,R>
Request/reply operations.- Since:
- 2.1.3
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RequestReplyFuture<K,V,R>
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>
sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, java.time.Duration replyTimeout)
Send a request and receive a reply.
-
-
-
Method Detail
-
sendAndReceive
RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
Send a request and receive a reply with the default timeout.- Parameters:
record
- the record to send.- Returns:
- a RequestReplyFuture.
-
sendAndReceive
RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, @Nullable java.time.Duration replyTimeout)
Send a request and receive a reply.- Parameters:
record
- the record to send.replyTimeout
- the reply timeout; if null, the default will be used.- Returns:
- a RequestReplyFuture.
- Since:
- 2.3
-
-