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* -- <https://grofers.com>
