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 and 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)
static java.lang.String	getGroupId()

Method Detail

getGroupId

@Nullable
static java.lang.String getGroupId()

commonHeaders

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,
                           @Nullable
                           java.lang.Object timestampType,
                           java.lang.Object timestamp)