1.基本概念：Kafka 是分布式发布 - 订阅消息系统，具有高吞吐量、可扩展性等优势，支持点对点和发布订阅两种消息模式，涉及 Broker、Topic、Partition 等多种角色。
2.安装步骤：需先安装 JDK 和 Zookeeper，下载 Kafka 安装包并解压，修改 server.properties 配置文件，包括 broker.id、listeners、log.dirs 等参数，分发安装包到其他节点并修改相应配置，启动前确保 Zookeeper 已启动。
（1）启动kafka集群
（2）进到 user/local/bin里创建脚本kafka.sh并编辑
（3）vi kafka.sh
#!/bin/bash
case $1 in
"start"){
echo "----启动 Kafka 集群----"
# 启动当前节点（node01）
kafka-server-start.sh -daemon /opt/software/kafka/config/server.properties
# 远程启动 node02 和 node03（需提前配置 SSH 免密登录）
ssh node02 "source /etc/profile; kafka-server-start.sh -daemon /opt/software/kafka/config/server.properties"
ssh node03 "source /etc/profile; kafka-server-start.sh -daemon /opt/software/kafka/config/server.properties"
};;
"stop"){
echo "----停止 Kafka 集群----"
# 停止当前节点（node01）
kafka-server-stop.sh
# 远程停止 node02 和 node03
ssh node02 "source /etc/profile; kafka-server-stop.sh"
ssh node03 "source /etc/profile; kafka-server-stop.sh"
};;
Esac
（4）赋予所有用户执行权限chmod 777 kafka.sh
（5）启动集群kafka.sh start
（6）查询进程xcall.sh jps
