1. 下載與解壓
- 官方下載 Kafka 2.7.0
https://archive.apache.org/dist/kafka/2.7.0/kafka_2.13-2.7.0.tgz
- 上傳到虛擬機（如?/home/wang/soft/kafka）
- 解壓：
? ?tar -zxvf kafka_2.13-2.7.0.tgz?
2. 配置環境變量（可選，便于命令行操作）
編輯?~/.bashrc?或?/etc/profile，追加：
export KAFKA_HOME=/home/wang/soft/kafka/kafka_2.13-2.7.0
export PATH=$PATH:$KAFKA_HOME/bin
?保存后刷新，變量才會生效：
source /etc/profile
3. 啟動 Zookeeper
Kafka 2.x 需要 Zookeeper，Kafka自帶了Zookeeper腳本，直接啟動即可：
cd /home/wang/soft/kafka/kafka_2.13-2.7.0
bin/zookeeper-server-start.sh config/zookeeper.properties
建議用?XShell?新開一個終端窗口運行，保持Zookeeper進程不被關閉。?
4. 啟動 Kafka
再開一個新終端，執行：
cd /home/wang/soft/kafka/kafka_2.13-2.7.0
bin/kafka-server-start.sh config/server.properties
同樣建議保持窗口開啟。
5. 驗證 Kafka 是否啟動成功
查看進程：
? jps
應該能看到?QuorumPeerMain（Zookeeper）和?Kafka?進程。
- 查看端口：
? netstat -tlnp | grep 9092
?Kafka默認監聽9092端口。
6. 創建 Topic 并測試生產/消費
創建 topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
?查看 topic 列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
啟動生產者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test?
輸入內容回車即可發送消息。
啟動消費者（新開一個終端）
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
你在生產者窗口輸入的內容會實時顯示在消費者窗口。
7. 常見問題
- 端口被占用：9092（Kafka）、2181（Zookeeper）如被占用，需修改配置或釋放端口。
- JDK版本不兼容：確保用的是JDK 1.8。
- Zookeeper未啟動：Kafka必須先啟動Zookeeper。
8. 停止服務
停止Kafka：
?? bin/kafka-server-stop.sh
停止Zookeeper：
? bin/zookeeper-server-stop.sh
總結：
你可以這樣操作：
- 下載、解壓Kafka
- 啟動Zookeeper（一個終端）
- 啟動Kafka（另一個終端）
- 創建topic并測試生產/消費
)
