reactor.kafka.sender

Class SenderRecord<K,V,T>

java.lang.Object

org.apache.kafka.clients.producer.ProducerRecord<K,V>

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 org.apache.kafka.clients.producer.ProducerRecord<K,V>

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(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, T correlationMetadata) Converts a ProducerRecord a SenderRecord to send to Kafka.
static <K,V,T> SenderRecord<K,V,T>	create(String topic, Integer partition, Long timestamp, K key, V value, T correlationMetadata) Creates a SenderRecord to send to Kafka.

Methods inherited from class org.apache.kafka.clients.producer.ProducerRecord

equals, hashCode, headers, key, partition, timestamp, topic, toString, value

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

create

public static <K,V,T> SenderRecord<K,V,T> create(org.apache.kafka.clients.producer.ProducerRecord<K,V> record,
                                                 T correlationMetadata)

Converts a ProducerRecord a SenderRecord 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 KafkaSender.send(org.reactivestreams.Publisher)

create

public static <K,V,T> SenderRecord<K,V,T> create(String topic,
                                                 Integer partition,
                                                 Long timestamp,
                                                 K key,
                                                 V value,
                                                 T correlationMetadata)

Creates a SenderRecord to send to Kafka.

Parameters:

topic - Topic to which record is sent

partition - The partition to which the record is sent. If null, the partitioner configured for the KafkaSender will be used to choose the partition.

timestamp - The timestamp of the record. If null, the current timestamp will be assigned by the producer. The timestamp will be overwritten by the broker if the topic is configured with TimestampType.LOG_APPEND_TIME. The actual timestamp used will be returned in SenderResult.recordMetadata()

key - The key to be included in the record. May be null.

value - The contents to be included in the record.

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 KafkaSender.send(org.reactivestreams.Publisher)

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