Hi, While joining streams from 2 partitions to join 2 streams, we see that some containers start suffering in that, lag (messages behind high watermark) for one of the tasks starts sky rocketing while the other one is ~ 0.
We are using default values for buffer sizes, fetch threshold, are using 4 threads as part of the pool and are using the default RoundRobinMessageChooser. Happy to share more details/config if it can help to debug this further. Thanks Ankit