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 Details

    • getGroupId

      static @Nullable String getGroupId()
      Get the thread bound group id.
      Returns:
      the group id.
    • 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.