首页 文章

Kafka 0.8中经纪人的分区重新 balancer

提问于
浏览
5

Kafka 0.8的相对稀缺的文档没有提到 balancer 现有主题,分区和经纪人副本的预期行为 .

更具体地说,经纪人到达时的预期行为和经纪人(领导者与否)的崩溃是什么?

谢谢 .

1 回答

  • 1

    我刚刚测试了这两个案例而不是在重载下 . 我有一个 生产环境 者同步发送10k消息(只是一个小字符串)到一个主题,复制因子为2,有2个分区,在2个代理的集群上 . 有2个消费者 . 每个组件都部署在单独的计算机上 . 我观察到的是:

    • On normal operation :代理1是分区1上的领导者和分区2上的副本 . 代理2是分区2上的领导者和分区1上的副本 . 将代理3引入群集不会自动触发分区上的重新 balancer .

    • On broker revival (crashed than reboot) :重新 balancer 对 生产环境 者和消费者是透明的 . 重新引导代理首先复制日志,然后使其自身可用 .

    • On broker crashed (leader or not) :在任何一个经纪商上由 kill -9 模拟 . 生产环境 者和消费者被冻结,直到被杀死的经纪人的ZK中的短暂节点到期 . 之后,操作正常恢复 .

相关问题