[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16965704#comment-16965704
]
Thomas Weise commented on FLINK-12675:
--------------------------------------
[~wind_ljy] perhaps it would be best if you outline the next level of detail in
the design doc? We should avoid refactoring if possible, to minimize the
surface of these changes. I just checked and see that the universal consumer
(FlinkKafkaConsumer) does not share all the internals with older, Kafka version
specific implementation, so we can hopefully avoid touching those altogether.
> 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)
