首页 文章

为什么我们需要在Kafka Consumer Configuration中添加所有zookeeper节点

提问于
浏览
2

看起来我们需要在属性“zookeeper.connect”中添加所有zookeeper节点的ip地址来配置使用者 .

现在我的理解是,zookeeper集群有一个以故障安全方式管理的领导者 .

那么,为什么我们只能为zookeeper节点提供一个引导列表,就像它在Producer配置中完成一样(同时提供引导代理列表),它们应该提供有关整个zookeeper集群的元数据?

1 回答

  • 2

    您可以指定节点的子集 . 该列表中的节点仅用于获取与节点集群的初始连接,客户端将遍历列表,直到 Build 连接 . 通常第一个节点已启动且可用,因此客户端不必过多地进入列表 . 因此,您只需要在列表中添加额外的节点,具体取决于您的悲观程度 .

相关问题