Interface MessageConverter

All Known Subinterfaces:

BatchMessageConverter, RecordMessageConverter

All Known Implementing Classes:

BatchMessagingMessageConverter, ByteArrayJacksonJsonMessageConverter, ByteArrayJsonMessageConverter, BytesJacksonJsonMessageConverter, BytesJsonMessageConverter, JacksonJsonMessageConverter, JacksonProjectingMessageConverter, JsonMessageConverter, MessagingMessageConverter, ProjectingMessageConverter, StringJacksonJsonMessageConverter, 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(@Nullable Object acknowledgment, @Nullable Object consumer, Map<String,Object> rawHeaders, @Nullable Object theKey, Object topic, Object partition, Object offset, @Nullable Object timestampType, Object timestamp)	Set up the common headers.
static @Nullable String	getGroupId()	Get the thread bound group id.

Method Details

getGroupId

static @Nullable String getGroupId()

Get the thread bound group id.

Returns:

the group id.

commonHeaders

default void commonHeaders(@Nullable Object acknowledgment,
 @Nullable Object 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 (can be Acknowledgment or ShareAcknowledgment).

consumer - the consumer (can be Consumer or ShareConsumer).

rawHeaders - the raw headers map.

theKey - the key.

topic - the topic.

partition - the partition.

offset - the offset.

timestampType - the timestamp type.

timestamp - the timestamp.