Hi all,

Is there any way I can force Zookeeper/Kafka to rebalance new consumers
only for subset of total number of partitions. I have a situation where out
of 120 partitions 60 have been already consumed, but the zookeeper also
assigns these empty/inactive partitions as well for the re-balancing, I
want my resources to be used only for the partitions which still have some
messages left to read.

Thanks
-Pranay

Reply via email to