Robert Metzger created FLINK-4796:

             Summary: Extend SinkFunction to include also the event timestamp
                 Key: FLINK-4796
             Project: Flink
          Issue Type: Improvement
          Components: DataStream API
    Affects Versions: 1.2.0
            Reporter: Robert Metzger

The Kafka 0.10 connector supports writing event timestamps to Kafka.
Currently, the regular DataStream APIs don't allow user code to access the 
event timestamp easily. That's why the Kafka connector is using a custom 
operator ({{transform()}}) to access the event time.

With this JIRA, I would like to provide the event timestamp in the regular 
DataStream APIs.

Once I'll look into the issue, I'll post some proposals how to add the 

This message was sent by Atlassian JIRA

Reply via email to