confluent-kafka-python icon indicating copy to clipboard operation
confluent-kafka-python copied to clipboard

Consumer: pause(partitions) and rebalancing

Open almaz1213 opened this issue 2 years ago • 1 comments

Does Consumer.pause(partitions) cause other group members will poll messages? Will group rebalance be there?

Thanks in advance

almaz1213 avatar May 22 '22 08:05 almaz1213

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.

mhowlett avatar May 23 '22 14:05 mhowlett