Hi,
    I have written a streams application to talk to topic on cluster of 5
brokers with 10 partitions. I have tried multiple combinations here like 10
application instances (on 10 different machines) with 1 stream thread each,
5 instances with 2 threads each. But for some reason, when I check in kafka
manager, the 1:1 mapping between partition and stream thread is not
happening. Some of the threads are picking up 2 partitions while some
picking up none. Can you please help me with same?? All threads are part of
same group and subscribed to only one topic.

Thanks a lot for your help
Kaustubh

Reply via email to