第 4 章 运行多节点环境
多节点环境包含作为集群运行的多个节点。您可以拥有复制 ZooKeeper 节点和代理节点集群,并在代理间复制主题。
多节点环境提供稳定性和可用性。
4.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/myidCopy to Clipboard Copied! Toggle word wrap Toggle overflow 例如:
su - kafka echo "1" > /var/lib/zookeeper/myid
su - kafka echo "1" > /var/lib/zookeeper/myidCopy 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.propertiesCopy to Clipboard Copied! Toggle word wrap Toggle overflow 验证 ZooKeeper 是否正在运行。
jcmd | grep zookeeper
jcmd | grep zookeeperCopy 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.propertiesCopy to Clipboard Copied! Toggle word wrap Toggle overflow - 在集群的所有节点上重复此步骤。
使用
ncat程序向每个节点发送stat命令,验证所有节点是否都是集群的成员。使用 ncat stat 检查节点状态
echo stat | ncat localhost 2181
echo stat | ncat localhost 2181Copy to Clipboard Copied! Toggle word wrap Toggle overflow 要使用 four-letter word 命令,如
stat,您需要在zookeeper.properties中指定4lw.commands.whitelist=*。输出显示节点
是领导或后续节点。ncat 命令的输出示例
Copy to Clipboard Copied! Toggle word wrap Toggle overflow