Hi all, In the javadoc for KafkaConsumer#pause <http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)> it's stated that,
Suspend fetching from the requested partitions. Future calls to poll(long) > <http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#poll%28long%29> > will not return any records from these partitions until they have been > resumed using resume(Collection) > <http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#resume%28java.util.Collection%29>. > Note that this method does not affect partition subscription. In > particular, it does not cause a group rebalance when automatic assignment > is used. > If a new consumer instance joins the group and the paused partition assigned to this consumer it starts to read data from that partition. How to pause a partition even if re-balance occurs ? Regards, Kamal C