Interface MessageConverter

All Known Subinterfaces:
BatchMessageConverter, RecordMessageConverter
All Known Implementing Classes:
BatchMessagingMessageConverter, ByteArrayJsonMessageConverter, BytesJsonMessageConverter, JsonMessageConverter, MessagingMessageConverter, ProjectingMessageConverter, StringJsonMessageConverter

public interface MessageConverter
A top level interface for message converters.
Since:
1.1
Author:
Gary Russell
  • Method Details

    • getGroupId

      @Nullable static String getGroupId()
      Get the thread bound group id.
      Returns:
      the group id.
    • commonHeaders

      default void commonHeaders(Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> 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.
      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.