[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942196#comment-16942196
]
Thomas Weise commented on FLINK-12675:
--------------------------------------
[~gerardg] yes it is still the plan to implement source synchronization for the
Kafka consumer. Just have not gotten around to work on this. If someone else is
interested to take this over, please let me know.
The implementation will be quite different from the Kinesis consumer.
Partitions are merged in the Kafka client and we will have to pause/resume
individual partitions while in the Kinesis case we can just control the
consumer thread in the record emitter.
> 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)
