第 3 章 运行多节点环境
多节点环境由多个节点组成,它们作为一个集群运行。您可以有一个复制的 ZooKeeper 节点集群和代理节点集群,以及代理中的复制。
多节点环境提供稳定性和可用性。
3.1. 运行多节点 ZooKeeper 集群 复制链接链接已复制到粘贴板!
配置并运行 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 返回:
number org.apache.zookeeper.server.quorum.QuorumPeerMain /opt/kafka/config/zookeeper.properties
number org.apache.zookeeper.server.quorum.QuorumPeerMain /opt/kafka/config/zookeeper.properties
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 要使用四个字母字命令,如
stat
,您需要在zookeeper.properties
中指定4lw.commands.whitelist=*
。输出显示节点
是领导
或遵循者
。ncat 命令的输出示例
Copy to Clipboard Copied! Toggle word wrap Toggle overflow