Thomas Weise created FLINK-12675:
------------------------------------
Summary: Event time synchronization in Kafka consumer
Key: FLINK-12675
URL: https://issues.apache.org/jira/browse/FLINK-12675
Project: Flink
Issue Type: Sub-task
Reporter: Thomas Weise
Assignee: Thomas WeiseIntegrate 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 (v7.6.3#76005)
