[CAMEL-16414] camel-kafka set custom timestamp

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.25.3, 3.8.0
• Fix Version/s: 3.10.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Ramu
• Reporter: Jens Kordowski
• Created: 26/Mar/21 15:01
• Updated: 14/Apr/21 08:03
• Resolved: 10/Apr/21 06:01

Description

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?

Issue Links

• is cloned by: CAMEL-16481 camel-vertx-kafka set custom timestamp
• links to: GitHub Pull Request #5312