org.springframework.kafka.support.converter

Class MessagingMessageConverter<K,V>

java.lang.Object

org.springframework.kafka.support.converter.MessagingMessageConverter<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

MessageConverter<K,V>

public class MessagingMessageConverter<K,V>
extends java.lang.Object
implements MessageConverter<K,V>

The Messaging specific MessageConverter implementation.

Populates KafkaHeaders based on the ConsumerRecord onto the returned message.

Author:

Marius Bogoevici, Gary Russell

Constructor Summary

Constructors

Constructor and Description
MessagingMessageConverter()

Method Summary

Modifier and Type	Method and Description
protected V	extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record) Subclasses can convert the value; by default, it's returned as provided by Kafka.
void	setGenerateMessageId(boolean generateMessageId) Generate Message ids for produced messages.
void	setGenerateTimestamp(boolean generateTimestamp) Generate timestamp for produced messages.
org.springframework.messaging.Message<?>	toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessagingMessageConverter

public MessagingMessageConverter()

Method Detail

setGenerateMessageId

public void setGenerateMessageId(boolean generateMessageId)

Generate Message ids for produced messages. If set to false, will try to use a default value. By default set to false.

Parameters:

generateMessageId - true if a message id should be generated

setGenerateTimestamp

public void setGenerateTimestamp(boolean generateTimestamp)

Generate timestamp for produced messages. If set to false, -1 is used instead. By default set to false.

Parameters:

generateTimestamp - true if a timestamp should be generated

toMessage

public org.springframework.messaging.Message<?> toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
                                                          Acknowledgment acknowledgment)

Specified by:

toMessage in interface MessageConverter<K,V>

extractAndConvertValue

protected V extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)

Subclasses can convert the value; by default, it's returned as provided by Kafka.

Parameters:

record - the record.

Returns:

the value.