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
