一毡琉、安裝環(huán)境
Kafka集群安裝需要事先準備好JDK環(huán)境和Zookeeper集群環(huán)境虫腋。
JDK安裝：http://www.reibang.com/p/cff2b88883e4
Zookeeper集群安裝部署：http://www.reibang.com/p/e01a28e17580
二舍杜、Kafka安裝
kafka安裝包下載地址：http://kafka.apache.org/downloads
kafka學習鏈接：https://www.orchome.com/kafka/index
1.上傳安裝包，解壓
##上傳安裝包
[root@node01 local]# rz -b
##解壓
[root@node01 local]# tar -zxvf kafka_2.13-2.7.1.tgz
##解壓后的目錄為kafka_2.13-2.7.1重名命為kafka
[root@node01 local]# mv kafka_2.13-2.7.1 kafka
2.修改配置
## 進入配置目錄
[root@node01 kafka]# cd config/
## 編輯配置文件server.properties
[root@node01 config]# vim server.properties
配置文件參數(shù)說明：https://www.orchome.com/12
3.啟動kafka
##切換至bin目錄下查看kafka啟動腳本
[root@node01 kafka]# cd bin
[root@node01 bin]# ll
##回車查看用法成艘，[-daemon] 以后臺方式啟動
[root@node01 bin]# ./kafka-server-start.sh
USAGE: ./kafka-server-start.sh [-daemon] server.properties [--override property=value]*
##啟動kafka
[root@node01 bin]# ./kafka-server-start.sh -daemon ../config/server.properties
##查看9092端口是否已被監(jiān)聽瞻佛，確保kafka啟動
[root@node01 bin]# netstat -ntpl |grep 9092
tcp6 0 0 192.168.203.10:9092 :::* LISTEN 10993/java
同樣的，其他兩臺節(jié)點服務器也安裝上kafka嘲玫，配置文件中broker.id分別改成對應的服務器id（本人把節(jié)點2配置成broker.id=2，節(jié)點3配置成broker.id=3并扇，可自定義去团，id號保證唯一就行）。
其他兩臺啟動kafka后穷蛹，kafka集群搭建完畢土陪。
4.檢查測試
切換到zookeeper的bin目錄下，登錄zookeeper的客戶端肴熏，可發(fā)現(xiàn)/brokers/ids鬼雀，查到已經(jīng)安裝的三臺kafka的broker.id[1,2,3]。
[root@node01 bin]# ./zkCli.sh -server 192.168.203.10:2181
5.一鍵啟動Kafka集群
編寫批量啟動kafka的腳本
[root@node01 kafka]# vim kfk_run_all.sh
腳本內(nèi)容：
#!/bin/bash
case $1 in
"start"){
for node in node01 node02 node03
do
echo "---------$node---------"
ssh $node "source /etc/profile;/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties"
done
};;
"stop"){
for node in node01 node02 node03
do
echo "---------$node---------"
ssh $node "source /etc/profile;/usr/local/kafka/bin/kafka-server-stop.sh"
done
};;
esac
node01,node02,node03是三臺節(jié)點的hostname蛙吏。先vim /etc/hosts 進行節(jié)點ip和hostname的映射源哩。然后通過ssh hostname遠程登入后進行操作。
給腳本賦權
[root@node01 kafka]# chmod +x kfk_run_all.sh
運行批量啟動腳本
[root@node01 kafka]# sh kfk_run_all.sh start
6.安裝過程問題解決
啟動報錯：Error exists in the bytecode
解決方法：升級jdk版本
參考鏈接：http://www.reibang.com/p/fd5d40f61d85
參考鏈接：
https://blog.csdn.net/qq_37989076/article/details/89241088
https://blog.csdn.net/Smallc0de/article/details/107749787
https://www.cnblogs.com/ding2016/p/8282907.html
