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