[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16965425#comment-16965425
]
Thomas Weise commented on FLINK-12675:
--------------------------------------
[~wind_ljy] FLIP-27 has still ways to go and is going to result in brand new
implementations for some of the existing connectors, while the old
implementations that are used in production will need to be retained for a
while until new things reach parity and maturity. The purpose of pointing you
to FLIP-27 is not to arrive at compatible solutions (which is impossible) but
rather as input for specific aspects such as the record and watermark emitter.
It would be great if you continue your work for the existing consumer, or else
I can maybe pick it up as we will need this problem solved fairly soon.
> 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)
