public interface MessageConverter
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)
Set up the common headers.
|
static java.lang.String |
getGroupId()
Get the thread bound group id.
|
@Nullable static java.lang.String getGroupId()
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)
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.