3.4. 运行单节点 Kafka 集群
此流程演示了如何运行由单个 Apache ZooKeeper 节点和单个 Apache Kafka 节点组成的基本 AMQ Streams 集群,它们在同一主机上运行。默认配置文件用于 ZooKeeper 和 Kafka。
警告
单一节点 AMQ Streams 集群不提供可靠性和高可用性,仅适用于开发目的。
先决条件
- AMQ Streams 安装在主机上
运行集群
编辑 ZooKeeper 配置文件
/opt/kafka/config/zookeeper.properties
。将dataDir
选项设置为/var/lib/zookeeper/
:dataDir=/var/lib/zookeeper/
dataDir=/var/lib/zookeeper/
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 编辑 Kafka 配置文件
/opt/kafka/config/server.properties
。将log.dirs
选项设置为/var/lib/kafka/
:log.dirs=/var/lib/kafka/
log.dirs=/var/lib/kafka/
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 切换到
kafka
用户:su - kafka
su - kafka
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 启动 ZooKeeper:
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
/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 启动 Kafka:
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 检查 Kafka 是否正在运行:
jcmd | grep kafka
jcmd | grep kafka
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 返回:
number kafka.Kafka /opt/kafka/config/server.properties
number kafka.Kafka /opt/kafka/config/server.properties
Copy to Clipboard Copied! Toggle word wrap Toggle overflow