Hi, really appreciate if anyone can help with this question, thanks! 🙂 What are the options to sync input streams in time? https://stackoverflow.com/questions/75591993/in-flink-is-there-a-way-to-restrict-processing-in-strict-event-time-ordering

If you've got a time boundary under which your messages can be out of order (say 5 seconds max), then you can use event time notion with a

forBoundedOutOfOrderness

Watermark strategy set on

10

seconds for example. This way your job will be always

10

late but will make sure your messages are processed in order