Class VertxKafkaHeadersPropagation
- java.lang.Object
-
- org.apache.camel.component.vertx.kafka.VertxKafkaHeadersPropagation
-
public final class VertxKafkaHeadersPropagation extends Object
-
-
Constructor Summary
Constructors Constructor Description VertxKafkaHeadersPropagation(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<String,io.vertx.core.buffer.Buffer>
getPropagatedHeaders(List<io.vertx.kafka.client.producer.KafkaHeader> headers, org.apache.camel.Message message)
List<io.vertx.kafka.client.producer.KafkaHeader>
getPropagatedHeaders(org.apache.camel.Message message)
-
-
-
Method Detail
-
getPropagatedHeaders
public List<io.vertx.kafka.client.producer.KafkaHeader> getPropagatedHeaders(org.apache.camel.Message message)
-
-