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 voidcommonHeaders(@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 StringGet 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.
-