org.springframework.kafka.requestreply

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

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.

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