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
The following commit(s) were added to refs/heads/master by this push:
new 8205198 CAMEL-12235 - Added timestamp to message header
8205198 is described below
commit 820519808d159d846bbbab1b645c28b164542346
Author: Anand Banik <[email protected]>
AuthorDate: Tue Feb 6 13:16:21 2018 -0600
CAMEL-12235 - Added timestamp to message header
---
.../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 ee66c83..545273d 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
@@ -25,6 +25,7 @@ public final class KafkaConstants {
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";
+ public static final String TIMESTAMP = "kafka.TIMESTAMP";
@Deprecated
public static final String KAFKA_DEFAULT_ENCODER =
"kafka.serializer.DefaultEncoder";
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 da2dc97..52e4ed5 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
@@ -173,6 +173,7 @@ public class KafkaEndpoint extends DefaultEndpoint
implements MultipleConsumersS
message.setHeader(KafkaConstants.TOPIC, record.topic());
message.setHeader(KafkaConstants.OFFSET, record.offset());
message.setHeader(KafkaConstants.HEADERS, record.headers());
+ message.setHeader(KafkaConstants.TIMESTAMP, record.timestamp());
if (record.key() != null) {
message.setHeader(KafkaConstants.KEY, record.key());
}
--
To stop receiving notification emails like this one, please contact
[email protected].
