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.