[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966690#comment-16966690 ]
Thomas Weise commented on FLINK-12675: -------------------------------------- [https://lists.apache.org/thread.html/a168a3634a329d1a2c278f660c995f98d821585e75eabe7c38629def@%3Cdev.flink.apache.org%3E] > Event time synchronization in Kafka consumer > -------------------------------------------- > > Key: FLINK-12675 > URL: https://issues.apache.org/jira/browse/FLINK-12675 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Kafka > Reporter: Thomas Weise > Assignee: Thomas Weise > Priority: Major > > Integrate the source watermark tracking into the Kafka consumer and implement > the sync mechanism (different consumer model, compared to Kinesis). -- This message was sent by Atlassian Jira (v8.3.4#803005)