org.springframework.kafka.support.converter

Interface BatchMessageConverter

All Superinterfaces:

MessageConverter

All Known Implementing Classes:

BatchMessagingMessageConverter

public interface BatchMessageConverter
extends MessageConverter

A Kafka-specific Message converter strategy.

Since:

1.1

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
java.util.List<org.apache.kafka.clients.producer.ProducerRecord<?,?>>	fromMessage(org.springframework.messaging.Message<?> message, java.lang.String defaultTopic) Convert a message to a producer record.
org.springframework.messaging.Message<?>	toMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, Acknowledgment acknowledgment, java.lang.reflect.Type payloadType) Convert a list of ConsumerRecord to a Message.

Method Detail

toMessage

org.springframework.messaging.Message<?> toMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
                                                   Acknowledgment acknowledgment,
                                                   java.lang.reflect.Type payloadType)

Convert a list of ConsumerRecord to a Message.

Parameters:

records - the records.

acknowledgment - the acknowledgment.

payloadType - the required payload type.

Returns:

the message.

fromMessage

java.util.List<org.apache.kafka.clients.producer.ProducerRecord<?,?>> fromMessage(org.springframework.messaging.Message<?> message,
                                                                                  java.lang.String defaultTopic)

Convert a message to a producer record.

Parameters:

message - the message.

defaultTopic - the default topic to use if no header found.

Returns:

the producer records.