[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16967243#comment-16967243 ]
Jiayi Liao commented on FLINK-12675: ------------------------------------ [~thw] Since the FLIP-27 design will be updated soon according to the mail thread, I'm going to help to review the updated design and continue the work after that. > 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)