[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355026#comment-16355026 ] ASF GitHub Bot commented on CAMEL-12235: oscerd commented on issue #2210: CAMEL-12235 - Added timestamp to message header URL: https://github.com/apache/camel/pull/2210#issuecomment-363672037 Merged. Thanks This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355028#comment-16355028 ] ASF GitHub Bot commented on CAMEL-12235: Github user oscerd closed the pull request at: https://github.com/apache/camel/pull/2210 > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355027#comment-16355027 ] ASF GitHub Bot commented on CAMEL-12235: oscerd closed pull request #2210: CAMEL-12235 - Added timestamp to message header URL: https://github.com/apache/camel/pull/2210 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): 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 ee66c8350b1..545273d6536 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 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 da2dc97cbb1..52e4ed54f08 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 Exchange createKafkaExchange(ConsumerRecord record) { 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()); } This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354975#comment-16354975 ] ASF GitHub Bot commented on CAMEL-12235: anandbanik commented on issue #2210: CAMEL-12235 - Added timestamp to message header URL: https://github.com/apache/camel/pull/2210#issuecomment-363659326 thanks, Andrea! This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354461#comment-16354461 ] ASF GitHub Bot commented on CAMEL-12235: oscerd commented on issue #2210: CAMEL-12235 - Added timestamp to message header URL: https://github.com/apache/camel/pull/2210#issuecomment-363543911 I'll merge tomorrow. Thanks This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354424#comment-16354424 ] Anand Banik commented on CAMEL-12235: - Create a PR # 2210 for this issue. Please review and let me know. > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354417#comment-16354417 ] ASF GitHub Bot commented on CAMEL-12235: anandbanik opened a new pull request #2210: CAMEL-12235 - Added timestamp to message header URL: https://github.com/apache/camel/pull/2210 Currently, the timestamp of the message produced by the publisher cannot be accessed by the Message API in the custom processor where the message is being consumed. This improvement adds the timestamp to the Message Header. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component
[ https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354418#comment-16354418 ] ASF GitHub Bot commented on CAMEL-12235: GitHub user anandbanik opened a pull request: https://github.com/apache/camel/pull/2210 CAMEL-12235 - Added timestamp to message header Currently, the timestamp of the message produced by the publisher cannot be accessed by the Message API in the custom processor where the message is being consumed. This improvement adds the timestamp to the Message Header. You can merge this pull request into a Git repository by running: $ git pull https://github.com/anandbanik/camel CAMEL-12235 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/camel/pull/2210.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2210 commit 114f47f369957f2af97049b2c5b0c5116a1f6cde Author: Anand Banik Date: 2018-02-06T19:16:21Z CAMEL-12235 - Added timestamp to message header > Add Timestamp to Message header from ConsumerRecord in the camel-kafka > component > -- > > Key: CAMEL-12235 > URL: https://issues.apache.org/jira/browse/CAMEL-12235 > Project: Camel > Issue Type: Improvement > Components: camel-kafka >Affects Versions: 2.21.0 >Reporter: Anand Banik >Priority: Minor > Fix For: 2.21.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > Currently, the timestamp of the message produced by the publisher cannot be > accessed by the Message API in the custom processor where the message is > being consumed. This improvement adds the timestamp to the Message Header. -- This message was sent by Atlassian JIRA (v7.6.3#76005)