我们有3个代理节点的kafka集群。当所有这些都启动并运行时，消费者能够从kafka读取数据。但是，如果我停止所有kafka服务器，并且只调出2个kafka服务器（最后停止的服务器除外），那么消费者将无法连接到kafka集群。这背后的原因是什么？提前谢谢。
kqhtkvqz1#
我猜问题可能是代理中的offsets.topic.replication.factor，默认情况下是3，而您现在运行的集群只有2个代理。这是使用者在消费时存储偏移量的主题，它是在第一次运行时使用复制因子3创建的。当第二次运行时，您只启动2个代理时，现在可能是问题所在。
1条答案
按热度按时间kqhtkvqz1#
我猜问题可能是代理中的offsets.topic.replication.factor，默认情况下是3，而您现在运行的集群只有2个代理。这是使用者在消费时存储偏移量的主题，它是在第一次运行时使用复制因子3创建的。当第二次运行时，您只启动2个代理时，现在可能是问题所在。