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 TypeMethodDescriptiondefault 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
Get the thread bound group id.
-
Method Details
-
getGroupId
-
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.
-