[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115924#comment-17115924
]
Aljoscha Krettek commented on FLINK-12675:
------------------------------------------
Sorry for chiming in this late but I think with recent developments I don't
think we should put more work into the existing Kafka connector and add more
complexity there. FLINK-10740 has mostly landed in master and Becket is working
on a Kafka Connector using the new interfaces. With the new interfaces, we
should also focus on solving even-time alignment at the framework level and not
for individual connectors.
[~becket_qin], could you please chime in with your progress here?
cc [~sewen] who's also working on FLIP-27 and might have a comment.
> 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: Akshay Aggarwal
> Priority: Major
> Labels: pull-request-available
> Attachments: 0001-Kafka-event-time-alignment.patch
>
>
> 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)
