reactor.kafka.sender

Class SenderRecord<K,V,T>

java.lang.Object

reactor.kafka.sender.SenderRecord<K,V,T>

Type Parameters:

K - Outgoing record key type

V - Outgoing record value type

T - Correlation metadata type

public class SenderRecord<K,V,T>
extends Object

Represents an outgoing record. Along with the record to send to Kafka, additional correlation metadata may also be specified to correlate SenderResult to its corresponding record.

Method Summary

Modifier and Type	Method and Description
T	correlationMetadata() Returns the correlation metadata associated with this instance which is not sent to Kafka, but can be used to correlate response to outbound request.
static <K,V,T> SenderRecord<K,V,T>	create(ProducerRecord<K,V> record, T correlationMetadata) Creates a record to send to Kafka.
ProducerRecord<K,V>	record() Returns the Kafka producer record associated with this instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static <K,V,T> SenderRecord<K,V,T> create(ProducerRecord<K,V> record,
                                                 T correlationMetadata)

Creates a record to send to Kafka.

Parameters:

record - the producer record to send to Kafka

correlationMetadata - Additional correlation metadata that is not sent to Kafka, but is included in the response to match SenderResult to this record.

Returns:

new sender record that can be sent to Kafka using Sender.send(org.reactivestreams.Publisher, boolean)

record

public ProducerRecord<K,V> record()

Returns the Kafka producer record associated with this instance.

Returns:

record to send to Kafka

correlationMetadata

public T correlationMetadata()

Returns the correlation metadata associated with this instance which is not sent to Kafka, but can be used to correlate response to outbound request.

Returns:

metadata associated with sender record that is not sent to Kafka