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:

3.2.1

Method Summary

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.

Method Detail

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.