You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have 10 input topics (a topic per mysql table) that I am reading from in my kafka streams app, certain topics have very low message rate while other have slightly higher message rate. Wonder if kafka streams processing on faster topics will be stalled due to low message rate on slower topics?
The text was updated successfully, but these errors were encountered:
No they should not, the brokers will manage the different loads for you automatically, that is why I also suggest to consume multiple topics with the same consumer instance, instead of spawning multiple instances for each topic.
I have 10 input topics (a topic per mysql table) that I am reading from in my kafka streams app, certain topics have very low message rate while other have slightly higher message rate. Wonder if kafka streams processing on faster topics will be stalled due to low message rate on slower topics?
The text was updated successfully, but these errors were encountered: