Hi,

I want to implement a flow where the data from one stream is needed to validate data for second stream when the job is started without a savepoint or checkpoint.

Both of them are reading from kafka. I want the data in the first one to be fully read and then to check the events from the second stream.

Do you have any suggestions how this could be achieved (maybe without window or just put events in a state and start a timer)?


Kind Regards

G.S.

Reply via email to