当另一个使用者加入同一个组时,分配给该使用者的所有暂停分区都将被吊销

mnemlml8  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(146)

我有一个消费者订阅了一个主题,它正在轮询3个分区。由于我的特定用例,这个使用者调用pause(topicpartition)方法,所以所有分区都将设置为paused。无论如何,它会继续轮询以发送心跳信号。然后,第二个消费者加入同一组。协调器重新平衡分区。预期这3个分区在两个使用者之间是平衡的,但是所有分区(3)从第一个使用者中被撤销,并且它们被分配给第二个使用者。
我可以在重新平衡时在我的第一个消费者中验证这一点(所有分区都处于暂停状态)。协调器调用ConsumerBalanceListener.onpartitionsrevoked,但从不调用ConsumerBalanceListener.onpartitionsassigned
为什么要从第一个使用者撤消所有分区?它与暂停的分区有关吗?在重新平衡暂停的分区时,有人经历过同样的行为吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题