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.