kafka0.8相对较少的文档没有提到在代理上平衡现有主题、分区和副本的预期行为。更具体地说，什么是预期的行为，在到达一个经纪人和崩溃的经纪人（领导或没有）？谢谢。
vql8enpb1#
我已经测试了这两个案件前一段时间，而不是在重负荷。我让一个生产者在一个由2个代理组成的集群上，同步地向一个主题发送10k条消息（只有一个小字符串），复制因子为2，有2个分区。有2个消费者。每个组件都部署在单独的计算机上。我观察到的是：在正常操作中：代理1在分区1上是前导，在分区2上是副本。代理2在分区2上是前导，在分区1上是副本。将broker 3引入集群不会自动触发分区上的重新平衡。关于经纪人的复苏（崩溃而不是重启）：重新平衡对生产者和消费者来说是透明的。重新启动的代理首先复制日志，然后使其自身可用。在代理崩溃（领导或没有）：模拟杀死任何一个代理9。生产者和消费者被冻结，直到被杀死的代理的zk中的临时节点过期。之后，操作恢复正常。
1条答案
按热度按时间vql8enpb1#
我已经测试了这两个案件前一段时间，而不是在重负荷。我让一个生产者在一个由2个代理组成的集群上，同步地向一个主题发送10k条消息（只有一个小字符串），复制因子为2，有2个分区。有2个消费者。每个组件都部署在单独的计算机上。我观察到的是：
在正常操作中：代理1在分区1上是前导，在分区2上是副本。代理2在分区2上是前导，在分区1上是副本。将broker 3引入集群不会自动触发分区上的重新平衡。
关于经纪人的复苏（崩溃而不是重启）：重新平衡对生产者和消费者来说是透明的。重新启动的代理首先复制日志，然后使其自身可用。
在代理崩溃（领导或没有）：模拟杀死任何一个代理9。生产者和消费者被冻结，直到被杀死的代理的zk中的临时节点过期。之后，操作恢复正常。