Package org.springframework.kafka.support

Interface KafkaHeaderMapper

All Known Implementing Classes:
AbstractKafkaHeaderMapper, DefaultKafkaHeaderMapper, SimpleKafkaHeaderMapper
public interface KafkaHeaderMapper
Header mapper for Apache Kafka.
Since:
1.3
Author:
Gary Russell

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    fromHeaders(MessageHeaders headers, org.apache.kafka.common.header.Headers target)
    Map from the given MessageHeaders to the specified target headers.
    void
    toHeaders(org.apache.kafka.common.header.Headers source, Map<String,Object> target)
    Map from the given native headers to a map of headers for the eventual MessageHeaders.

  • Method Details

    • fromHeaders

      void fromHeaders(MessageHeaders headers, org.apache.kafka.common.header.Headers target)
      Map from the given MessageHeaders to the specified target headers.
      Parameters:
      headers - the abstracted MessageHeaders.
      target - the native target headers.

    • toHeaders

      void toHeaders(org.apache.kafka.common.header.Headers source, Map<String,Object> target)
      Map from the given native headers to a map of headers for the eventual MessageHeaders.
      Parameters:
      source - the native headers.
      target - the target headers.