Hi, I think this is still on-going effort. You can monitor the corresponding issues [1] and [2].
Best, Andrey [1] https://issues.apache.org/jira/browse/FLINK-8500 <https://issues.apache.org/jira/browse/FLINK-8500> [2] https://issues.apache.org/jira/browse/FLINK-8354 > On 16 Nov 2018, at 09:41, Flink Developer <developer...@protonmail.com> wrote: > > Kafka timestamp