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

Question

看来我们需要在 属性 "zookeeper.connect" 中添加所有 zookeeper 节点的 ip 地址以配置消费者。

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

那么，为什么我们不能像在生产者配置中那样为 zookeeper 节点提供 bootstrap 列表（同时提供 bootstrap 代理列表）并且它们应该提供有关整个 zookeeper 集群的元数据？

Answer 1

您可以指定节点的子集。该列表中的节点仅用于获得与节点集群的初始连接，客户端遍历该列表直到建立连接。通常第一个节点已启动并可用，因此客户端不必在列表中走得太远。所以你只需要根据你的悲观程度向列表添加额外的节点。