Hello, I had this question myself and I've seen it a few times, the answer is always the same, there's currently no official way to handle it without state.
Regards, Alexis. On Mon, 27 Feb 2023, 14:09 Remigiusz Janeczek, <capi...@gmail.com> wrote: > 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 >
