[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966726#comment-16966726 ]
Jiayi Liao commented on FLINK-12675: ------------------------------------ [~thw] Thanks for attaching this. I've already given attention to this :). And I'll elaborate more details in design in these days. > 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)