[BEAM-3851] Support element timestamps while publishing to Kafka.

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.3.0
• Fix Version/s: 2.5.0
• Component/s: io-java-kafka
• Assignee: Raghu Angadi
• Reporter: Raghu Angadi
• Created: 14/Mar/18 18:09
• Updated: 16/May/20 13:40
• Resolved: 30/Apr/18 04:49

Description

KafkaIO sink should support using input element timestamp for the message published to Kafka. Otherwise there is no way for user to influence the timestamp of the messages in Kafka sink.

Issue Links

• links to: GitHub Pull Request #4868