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