3.3. 运行多节点 ZooKeeper 集群
此流程演示了如何将 ZooKeeper 配置为多节点集群。
在 ZooKeeper 3.5.7 中,必须在使用前将 四个字母单词 添加到 allow 列表中。如需更多信息,请参阅 ZooKeeper 文档。
先决条件
- AMQ Streams 安装在用作 ZooKeeper 集群节点的所有主机上。
运行集群
在
/var/lib/zookeeper/
中创建myid
文件。为第一个 ZooKeeper 节点输入 ID1
,为第二个 ZooKeeper 节点输入2
,以此类推。su - kafka echo "<NodeID>" > /var/lib/zookeeper/myid
su - kafka echo "<NodeID>" > /var/lib/zookeeper/myid
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 例如:
su - kafka echo "1" > /var/lib/zookeeper/myid
su - kafka echo "1" > /var/lib/zookeeper/myid
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 编辑 ZooKeeper
/opt/kafka/config/zookeeper.properties
配置文件:-
将选项
dataDir
设置为/var/lib/zookeeper/
。 -
配置
initLimit
和syncLimit
选项。 -
配置
reconfigEnabled
和standaloneEnabled
选项。 添加所有 ZooKeeper 节点的列表。该列表还应包含当前的节点。
具有五个成员的 ZooKeeper 集群节点配置示例
Copy to Clipboard Copied! Toggle word wrap Toggle overflow
-
将选项
使用默认配置文件启动 ZooKeeper。
su - kafka /opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
su - kafka /opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 验证 ZooKeeper 是否正在运行。
jcmd | grep zookeeper
jcmd | grep zookeeper
Copy to Clipboard Copied! Toggle word wrap Toggle overflow - 在集群的所有节点上重复此步骤。
当集群的所有节点都启动并运行后,使用
ncat
实用程序向每个节点发送stat
命令,以验证所有节点是否都是集群的成员。使用 ncat stat 检查节点状态
echo stat | ncat localhost 2181
echo stat | ncat localhost 2181
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 要使用包括四个字母的命令,如
dump
,需要在zookeeper.properties
中指定4lw.commands.whitelist=*
。在输出中,您应该会看到节点为
leader
或follower
的信息。ncat
命令的输出示例Copy to Clipboard Copied! Toggle word wrap Toggle overflow
其他资源
- 有关安装 AMQ Streams 的详情,请参考 第 2.3 节 “安装 AMQ Streams”。
- 有关配置 AMQ Streams 的详情,请参考 第 2.8 节 “配置 AMQ Streams”。