K
- the key type.V
- the outbound data type.R
- the reply data type.public interface ReplyingKafkaOperations<K,V,R>
Modifier and Type | Method and 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.
|
RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
record
- the record to send.RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, @Nullable java.time.Duration replyTimeout)
record
- the record to send.replyTimeout
- the reply timeout; if null, the default will be used.