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:

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.

Method Detail

sendAndReceive

RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)

Send a request and receive a reply.

Parameters:

record - the record to send.

Returns:

a RequestReplyFuture.