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 Summary

    Modifier and Type
    Method
    Description
    default void
    commonHeaders(@Nullable Acknowledgment acknowledgment, @Nullable 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.
    static @Nullable String
    getGroupId()
    Get the thread bound group id.

  • Method Details

    • getGroupId

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

    • commonHeaders

      default void commonHeaders(@Nullable Acknowledgment acknowledgment, @Nullable 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 offset.
      timestampType - the timestamp type.
      timestamp - the timestamp.