Hi, Have you checked out the Hybrid Source? [1]
Thanks, Martijn [1] https://ci.apache.org/projects/flink/flink-docs-master/docs/connectors/datastream/hybridsource/ On Fri, 15 Oct 2021 at 10:22, Akshay Agarwal <akshay.agar...@grofers.com> wrote: > Hi Team, > > I have a streaming job that creates an enriched stream from streams of 2 > different sources like one from files in object storage and another one > Kafka. But since both of these are from different sources, events from them > are read at different moments based on their performance. For example > events from Kafka arrives first than from file storage events and even > though I have used event watermarks, thus at the restart of jobs, enriched > events are wrong and it gets corrected after file events start arriving. I > tried to search for setting up synchronization between different sources in > flink but did not found any blog/material. It might be a noob question, but > if you guys have built something around this, could you let me know. > > Regards > *Akshay Agarwal* > > [image: https://grofers.com] <https://grofers.com>
