Package org.springframework.kafka.support.converter

Interface MessageConverter

All Known Subinterfaces:

BatchMessageConverter, RecordMessageConverter

All Known Implementing Classes:

BatchMessagingMessageConverter, ByteArrayJsonMessageConverter, BytesJsonMessageConverter, JsonMessageConverter, MessagingMessageConverter, ProjectingMessageConverter, StringJsonMessageConverter

public interface MessageConverter

A top level interface for message converters.

Since:

1.1

Author:

Gary Russell

Method Summary

Modifier and Type	Method	Description
default void	commonHeaders(Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Map<java.lang.String,java.lang.Object> rawHeaders, java.lang.Object theKey, java.lang.Object topic, java.lang.Object partition, java.lang.Object offset, java.lang.Object timestampType, java.lang.Object timestamp)	Set up the common headers.
static java.lang.String	getGroupId()	Get the thread bound group id.

Method Detail

getGroupId

@Nullable
static java.lang.String getGroupId()

Get the thread bound group id.

Returns:

the group id.

commonHeaders

default void commonHeaders(Acknowledgment acknowledgment,
                           org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
                           java.util.Map<java.lang.String,java.lang.Object> rawHeaders,
                           @Nullable
                           java.lang.Object theKey,
                           java.lang.Object topic,
                           java.lang.Object partition,
                           java.lang.Object offset,
                           @Nullable
                           java.lang.Object timestampType,
                           java.lang.Object timestamp)

Set up the common headers.

Parameters:

acknowledgment - the acknowledgment.

consumer - the consumer.

rawHeaders - the raw headers map.

theKey - the key.

topic - the topic.

partition - the partition.

offset - the offfset.

timestampType - the timestamp type.

timestamp - the timestamp.