Raghu Angadi created BEAM-3851: ---------------------------------- Summary: Support element timestamps while publishing to Kafka. Key: BEAM-3851 URL: https://issues.apache.org/jira/browse/BEAM-3851 Project: Beam Issue Type: Improvement Components: io-java-kafka Affects Versions: 2.3.0 Reporter: Raghu Angadi Assignee: Raghu Angadi Fix For: 2.4.0
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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)