confluent-kafka-python
confluent-kafka-python copied to clipboard
Consumer: pause(partitions) and rebalancing
Does Consumer.pause(partitions) cause other group members will poll messages? Will group rebalance be there?
Thanks in advance
pausing causes the consumer to stop fetching messages for the specified partitions (and calls to poll will never return messages for these partiitons).
it is independent of the behavior of consumer groups - paused partitions will remain assigned to the consumer, and may or may not be moved on a group rebalance. paused state does not move between consumer instances - partitions on one consumer instance that are moved to another during a rebalance will not stay paused.