我们在3个kafka节点的环境中测试scalein,每个节点在副本中都有一个broker和zookeeper服务。factor=2在服务在2个节点上停止后,分区的领导者保持原来的位置,没有移动到唯一一个启动的节点
并发送错误消息
错误:分区0没有前导。跳过获取偏移量错误:分区2没有引线。跳过获取偏移量错误:分区3没有引线。跳过获取偏移
为什么会这样?
在这里,您可以看到即使有副本集,领导者们是如何留下来的
我们在3个kafka节点的环境中测试scalein,每个节点在副本中都有一个broker和zookeeper服务。factor=2在服务在2个节点上停止后,分区的领导者保持原来的位置,没有移动到唯一一个启动的节点
并发送错误消息
错误:分区0没有前导。跳过获取偏移量错误:分区2没有引线。跳过获取偏移量错误:分区3没有引线。跳过获取偏移
为什么会这样?
在这里,您可以看到即使有副本集,领导者们是如何留下来的
1条答案
按热度按时间shstlldc1#
根据Kafka的配置
偏移量主题的复制因子(设置得更高以确保可用性)。在群集大小满足此复制因子要求之前,内部主题创建将失败。
我猜kafka集群不能服务于或做任何具有比集群大小更大的复制因子的主题