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)

Reply via email to