org.springframework.kafka.support.converter

Interface RecordMessageConverter

All Superinterfaces:

MessageConverter

All Known Implementing Classes:

ByteArrayJsonMessageConverter, BytesJsonMessageConverter, JsonMessageConverter, MessagingMessageConverter, ProjectingMessageConverter, StringJsonMessageConverter

public interface RecordMessageConverter
extends MessageConverter

A Kafka-specific Message converter strategy.

Since:

1.1

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
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(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.reflect.Type payloadType) Convert a ConsumerRecord to a Message.

Methods inherited from interface org.springframework.kafka.support.converter.MessageConverter

commonHeaders, getGroupId

Method Detail

toMessage

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

Convert a ConsumerRecord to a Message.

Parameters:

record - the record.

acknowledgment - the acknowledgment.

consumer - the consumer

payloadType - the required payload type.

Returns:

the message.

fromMessage

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 record.