apache-kafka - 当分区暂停并重新平衡时会发生什么?

标签 apache-kafka kafka-consumer-api

当 Kafka 分区被消费者暂停并触发重新平衡时会发生什么? 分区在分配给新消费者时保持暂停状态还是会恢复?

当我搜索它时,我得到了不同的答案。无法获取有关它的 Kafka 文档。

最佳答案

发生重新平衡时,所有分区都会恢复。

这是因为暂停分区是消费者本地的决定。该小组的其他成员并不知道这一点。

如果使用者中的逻辑可以根据某些条件暂停分区,则当重新分配分区时,您的逻辑可以根据相同的条件再次暂停它们。对于可能运行相同逻辑的其他消费者来说,同样的情况也会发生。


请注意,回答此类问题相对容易。您可以尝试一下,看看会发生什么。这也是提高您对 Kafka 理解的好方法!

关于apache-kafka - 当分区暂停并重新平衡时会发生什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63155791/

相关文章:

kubernetes - 如何创建自己的 Kubernetes Strimzi Operator Kafka 用户证书和 key ?

scala - Kafka 主题到 websocket

apache-kafka - 如何修复 0.10.2.1 kafka 中的 kafka 消费者滞后问题

apache-kafka - Kafka session.timeout.ms 和 max.poll.interval.ms 的区别

python - 如何以编程方式检查 Kafka Broker 是否已启动并在 Python 中运行

java - 如何监控 Kafka 消息的应用程序处理以进行负载测试

java - 清除检查点位置后 Spark 结构化流消耗的旧 Kafka 偏移量

angularjs - angular.js 与 apache kafka 集成

apache-kafka - enable.auto.commit 值未配置为 true

java - Kafka Consumer.poll 调用不返回 kafka ConsumerRecords