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, Map<String,Object> rawHeaders, Object theKey, Object topic, Object partition, Object offset, Object timestampType, Object timestamp)	Set up the common headers.
static String	getGroupId()	Get the thread bound group id.

Method Details

getGroupId

@Nullable
static 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,
 Map<String,Object> rawHeaders,
 @Nullable
 Object theKey,
 Object topic,
 Object partition,
 Object offset,
 @Nullable
 Object timestampType,
 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 offset.

timestampType - the timestamp type.

timestamp - the timestamp.