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(org.springframework.messaging.Message<?> message,
java.lang.String topic,
java.lang.Integer partition,
java.lang.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(org.springframework.messaging.Message<?> message, java.lang.String topic, java.lang.Integer partition, java.lang.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.