当消费者暂停kafka分区并触发重新平衡时会发生什么?分配给新使用者时,分区仍处于暂停状态,还是将恢复?我找的时候得到的答案不一。找不到Kafka的文件。
wecizke31#
当重新平衡发生时,所有分区都将恢复。这是因为暂停分区是使用者的本地决定。其他人对此并不清楚。如果使用者中的逻辑可以基于某些条件暂停分区,则在重新分配分区时,逻辑可以基于相同的条件再次暂停分区。同样的情况也会发生在运行相同逻辑的其他消费者身上。请注意,回答这类问题相对容易。你可以试试看会发生什么。这也是提高你对Kafka理解的好方法!
1条答案
按热度按时间wecizke31#
当重新平衡发生时,所有分区都将恢复。
这是因为暂停分区是使用者的本地决定。其他人对此并不清楚。
如果使用者中的逻辑可以基于某些条件暂停分区,则在重新分配分区时,逻辑可以基于相同的条件再次暂停分区。同样的情况也会发生在运行相同逻辑的其他消费者身上。
请注意,回答这类问题相对容易。你可以试试看会发生什么。这也是提高你对Kafka理解的好方法!