[jira] [Commented] (CAMEL-12235) Add Timestamp to Message header from ConsumerRecord in the camel-kafka component

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[Anand Banik (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/CAMEL-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)