Hi, How to handle a case where one of the Kafka topics used for interval join is slower than the other? (Or a case where one topic lags behind) Is there a way to stop consuming from the fast topic and wait for the slow one to catch up? I want to avoid running out of memory (or keeping a very large state) and I don't want to discard any data from the fast topic until a watermark from the slow topic allows that.
Best Regards
