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 Weise
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 (v7.6.3#76005)