我们在环境中使用 3 个 kafka 节点测试 scalein，每个节点在 replica.factor=2 上都有一个代理和 zookeeper 服务，在服务在 2 个节点上关闭后，分区的领导者保持旧节点并且没有移动到唯一的节点起来了
并发送一条错误消息
错误：分区 0 没有领导者。跳过获取偏移量错误：分区 2 没有领导者。跳过获取偏移量错误：分区 3 没有领导者。跳过获取偏移量
为什么会发生这种情况？
问问题
297 次
1 回答
0
根据kafka配置
偏移主题的复制因子（设置更高以确保可用性）。在集群大小满足此复制因子要求之前，内部主题创建将失败。
我猜 kafka 集群无法为具有大于其集群大小的副本因子的主题提供服务或做任何事情
于 2019-11-05T16:56:54.437 回答