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 others have slightly higher message rate. Rarely a couple of topics can have a surge of messages. Wonder if kafka streams processing on faster topics will be stalled due to low message rate on slower topics? And if I should create separate source nodes in the topology to isolate slower topics from faster topics.
My streams app extracts information from input message, goes to another service to get more data and writes it to an output kafka topic.