[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096462#comment-17096462
]
Akshay Aggarwal commented on FLINK-12675:
-----------------------------------------
[~wind_ljy] I've implemented the design you had attached earlier, since the
feature was becoming fairly important for us I quickly wrote the code without
worrying about the WatermarkTracker based approach. It seems to be working fine
when I tested it locally. The patch I've attached is on top of 1.10.0 release.
It'll be great if you can review it once, also I'd be happy to implement the
changes with WatermarkTracker if you can share some guidelines on dev and
testing.
[^0001-Kafka-event-time-alignment.patch]
> 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
> 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)
