You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@camel.apache.org by "Jens Kordowski (Jira)" <ji...@apache.org> on 2021/03/26 15:02:00 UTC

[jira] [Created] (CAMEL-16414) camel-kafka set custom timestamp

Jens Kordowski created CAMEL-16414:
--------------------------------------

             Summary: camel-kafka set custom timestamp
                 Key: CAMEL-16414
                 URL: https://issues.apache.org/jira/browse/CAMEL-16414
             Project: Camel
          Issue Type: Improvement
          Components: camel-kafka
    Affects Versions: 3.8.0, 2.25.3
            Reporter: Jens Kordowski


The kafka producer supports the possibility to pass on a (custom) timestamp with the record. The camel-kafka component does not leverage this, currently. A Camel header seems like a good option to provide this. The consumer already creates a kafka.TIMESTAMP header (not yet documented). I suggest to use a different header to avoid misconfiguration in case of "kafka to kafka" scenarios. kafka.OVERRIDE_TIMESTAMP (being a one-time header) looks like a good idea, similar to the existing kafka.OVERRIDE_TOPIC.

What do you think?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)