Class VertxKafkaHeadersPropagation


  • public final class VertxKafkaHeadersPropagation
    extends Object
    • Constructor Detail

      • VertxKafkaHeadersPropagation

        public VertxKafkaHeadersPropagation​(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
    • Method Detail

      • getPropagatedHeaders

        public List<io.vertx.kafka.client.producer.KafkaHeader> getPropagatedHeaders​(org.apache.camel.Message message)
      • getPropagatedHeaders

        public Map<String,​io.vertx.core.buffer.Buffer> getPropagatedHeaders​(List<io.vertx.kafka.client.producer.KafkaHeader> headers,
                                                                                  org.apache.camel.Message message)