K - the key type.V - the value type.@FunctionalInterface public static interface KafkaProducerMessageHandler.ProducerRecordCreator<K,V>
ProducerRecord from a Message and/or properties
derived from configuration and/or the message.| Modifier and Type | Method and Description |
|---|---|
org.apache.kafka.clients.producer.ProducerRecord<K,V> |
create(Message<?> message,
String topic,
Integer partition,
Long timestamp,
K key,
V value,
org.apache.kafka.common.header.Headers headers)
Create a record.
|
org.apache.kafka.clients.producer.ProducerRecord<K,V> create(Message<?> message, String topic, Integer partition, Long timestamp, K key, V value, org.apache.kafka.common.header.Headers headers)
message - the outbound message.topic - the topic.partition - the partition.timestamp - the timestamp.key - the key.value - the value.headers - the headers.