[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-04 Thread FredTing
Github user FredTing commented on the issue: https://github.com/apache/flink/pull/5939 I'm closing this Pull Request and will make a new one with the newer approach as discussed in the jira issue ---

[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-03 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5939 @FredTing Do avoid confusion we should probably close this PR. What do you think? ---

[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-03 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5939 @StephanEwen we have some follow-up discussion on how to approach this on the JIRA ticket. Do you want to take a look at that? https://issues.apache.org/jira/browse/FLINK-8500 The general i

[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5939 The feature is a nice addition. Flink currently already adds the timestamp as the record's event time timestamp. You can access it via a ProcessFunction. That is a tad bit more clumsy, t