Package org.springframework.integration.kafka.outbound

Interface KafkaProducerMessageHandler.ProducerRecordCreator<K,V>

Type Parameters:

K - the key type.

V - the value type.

Enclosing class:

KafkaProducerMessageHandler<K,V>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface KafkaProducerMessageHandler.ProducerRecordCreator<K,V>

Creates a ProducerRecord from a Message and/or properties derived from configuration and/or the message.

Since:

5.4

Method Summary

Modifier and Type	Method	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.

Method Details

create

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.

Parameters:

message - the outbound message.

topic - the topic.

partition - the partition.

timestamp - the timestamp.

key - the key.

value - the value.

headers - the headers.

Returns:

the record.