3.3. 运行多节点 ZooKeeper 集群

运行集群

1. 在 /var/lib/zookeeper/ 中创建 myid 文件。为第一个 ZooKeeper 节点输入 ID 1，为第二个 ZooKeeper 节点输入 2，以此类推。

   su - kafka
   echo "<NodeID>" > /var/lib/zookeeper/myid

   例如：

   su - kafka
   echo "1" > /var/lib/zookeeper/myid

2. 编辑 ZooKeeper /opt/kafka/config/zookeeper.properties 配置文件：

   • 将选项 dataDir 设置为 /var/lib/zookeeper/。
   • 配置 initLimit 和 syncLimit 选项。
   • 配置 reconfigEnabled 和 standaloneEnabled 选项。

   • 添加所有 ZooKeeper 节点的列表。该列表还应包含当前节点。

     具有五个成员的 ZooKeeper 集群配置示例

     timeTick=2000
     dataDir=/var/lib/zookeeper/
     initLimit=5
     syncLimit=2
     reconfigEnabled=true
     standaloneEnabled=false
     
     server.1=172.17.0.1:2888:3888:participant;172.17.0.1:2181
     server.2=172.17.0.2:2888:3888:participant;172.17.0.2:2181
     server.3=172.17.0.3:2888:3888:participant;172.17.0.3:2181
     server.4=172.17.0.4:2888:3888:participant;172.17.0.4:2181
     server.5=172.17.0.5:2888:3888:participant;172.17.0.5:2181

3. 使用默认配置文件启动 ZooKeeper。

   su - kafka
   /opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties

4. 验证 ZooKeeper 是否正在运行。

   jcmd | grep zookeeper

5. 在集群的所有节点上重复此步骤。

6. 当集群的所有节点都启动并运行后，使用 ncat 工具向每个节点发送 stat 命令来验证所有节点是否为集群成员。

   使用 ncat stat 检查节点状态

   echo stat | ncat localhost 2181

   在输出中，您应该看到该节点是 leader 或 follower 的信息。

   ncat 命令的输出示例

   ZooKeeper version: 3.4.13-2d71af4dbe22557fda74f9a9b4309b15a7487f03, built on 06/29/2018 00:39 GMT
   Clients:
    /0:0:0:0:0:0:0:1:59726[0](queued=0,recved=1,sent=0)
   
   Latency min/avg/max: 0/0/0
   Received: 2
   Sent: 1
   Connections: 1
   Outstanding: 0
   Zxid: 0x200000000
   Mode: follower
   Node count: 4