当分区暂停并重新平衡时会发生什么?
What happens when partition is paused and re-balance happens?
当 Kafka 分区被消费者暂停并触发重新平衡时会发生什么?
分区在分配给新消费者时保持暂停状态,否则会恢复?
我在搜索时得到了不同的答案。无法获取关于它的 Kafka 文档。
当重新平衡发生时,所有分区都会恢复。
这是因为暂停分区是消费者的本地决定。该组的其他人不知道这一点。
如果您在消费者中有可以根据某些条件暂停分区的逻辑,当重新分配分区时,您的逻辑可以根据相同的条件再次暂停它们。其他消费者可能也是如此 运行 相同的逻辑。
请注意,回答此类问题相对容易。您可以尝试一下,看看会发生什么。这也是提高您对 Kafka 的理解的好方法!
当 Kafka 分区被消费者暂停并触发重新平衡时会发生什么? 分区在分配给新消费者时保持暂停状态,否则会恢复?
我在搜索时得到了不同的答案。无法获取关于它的 Kafka 文档。
当重新平衡发生时,所有分区都会恢复。
这是因为暂停分区是消费者的本地决定。该组的其他人不知道这一点。
如果您在消费者中有可以根据某些条件暂停分区的逻辑,当重新分配分区时,您的逻辑可以根据相同的条件再次暂停它们。其他消费者可能也是如此 运行 相同的逻辑。
请注意,回答此类问题相对容易。您可以尝试一下,看看会发生什么。这也是提高您对 Kafka 的理解的好方法!