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




Reply via email to