3.4. 运行单节点 Kafka 集群
此流程演示了如何对 Apache Kafka 集群运行基本流,它由单个 Apache ZooKeeper 节点和一个 Apache Kafka 节点组成,它们在同一主机上运行。默认配置文件用于 Kafka。
警告
单个用于 Apache Kafka 集群的节点流不提供可靠性和高可用性,且仅适用于开发目的。
先决条件
- 在主机上安装了 Apache Kafka 的流
运行集群
为 Kafka 集群生成唯一 ID。
您可以使用
kafka-storage工具进行此操作:/opt/kafka/bin/kafka-storage.sh random-uuid
/opt/kafka/bin/kafka-storage.sh random-uuidCopy to Clipboard Copied! Toggle word wrap Toggle overflow 该命令返回一个 ID。
注意KRaft 模式需要一个集群 ID。
编辑 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 - kafkaCopy 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.propertiesCopy to Clipboard Copied! Toggle word wrap Toggle overflow 检查 Kafka 是否正在运行:
jcmd | grep kafka
jcmd | grep kafkaCopy to Clipboard Copied! Toggle word wrap Toggle overflow 返回:
process ID kafka.Kafka /opt/kafka/config/server.properties
process ID kafka.Kafka /opt/kafka/config/server.propertiesCopy to Clipboard Copied! Toggle word wrap Toggle overflow