Interface KafkaHeaderMapper

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void fromHeaders​(org.springframework.messaging.MessageHeaders headers, org.apache.kafka.common.header.Headers target)
      Map from the given MessageHeaders to the specified target message.
      void toHeaders​(org.apache.kafka.common.header.Headers source, java.util.Map<java.lang.String,​java.lang.Object> target)
      Map from the given target message to abstracted MessageHeaders.
    • Method Detail

      • fromHeaders

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

        void toHeaders​(org.apache.kafka.common.header.Headers source,
                       java.util.Map<java.lang.String,​java.lang.Object> target)
        Map from the given target message to abstracted MessageHeaders.
        Parameters:
        source - the native target message.
        target - the target headers.