Re: Pausing a partition in Kafka Consumer

2016-08-22 Thread Guozhang Wang
Hi Kamal, Thanks for reporting this. I think we can carry the paused partitions info across rebalances so that if the partitions are assigned to the consumers again they are still automatically paused (currently we reset such information after rebalance). Guozhang On Sun, Aug 21, 2016 at 10:10

Pausing a partition in Kafka Consumer

2016-08-21 Thread Kamal C
Hi all, In the javadoc for KafkaConsumer#pause it's stated that, Suspend fetching from the requested partitions. Future calls to poll(long) >