This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit b96c0f861fd604e6065c24b51cb60051413d0440 Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Oct 23 10:50:03 2017 +0200 CAMEL-11935 - Propagate Kafka record headers to camel headers --- .../src/main/java/org/apache/camel/component/kafka/KafkaConstants.java | 1 + .../src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java | 1 + 2 files changed, 2 insertions(+) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java index 70f98e2..3e94acb 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java @@ -23,6 +23,7 @@ public final class KafkaConstants { public static final String KEY = "kafka.KEY"; public static final String TOPIC = "kafka.TOPIC"; public static final String OFFSET = "kafka.OFFSET"; + public static final String HEADERS = "kafka.HEADERS"; public static final String LAST_RECORD_BEFORE_COMMIT = "kafka.LAST_RECORD_BEFORE_COMMIT"; @Deprecated diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java index 14932bf..3959324 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java @@ -171,6 +171,7 @@ public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersS message.setHeader(KafkaConstants.PARTITION, record.partition()); message.setHeader(KafkaConstants.TOPIC, record.topic()); message.setHeader(KafkaConstants.OFFSET, record.offset()); + message.setHeader(KafkaConstants.HEADERS, record.headers()); if (record.key() != null) { message.setHeader(KafkaConstants.KEY, record.key()); } -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
