我的kafka的3個節(jié)點是這樣的。

?

啟動kafka集群腳本

#!/bin/bash echo "kafka cluster start" ssh Desktop "source ~/.bashrc;$KAFKA/bin/kafka-server-start.sh -daemon $KAFKA/config/server.properties &" ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA2/bin/kafka-server-start.sh -daemon $KAFKA2/config/server.properties &" ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA3/bin/kafka-server-start.sh -daemon $KAFKA3/config/server.properties &"

關(guān)閉kafka集群腳本

#!/bin/bash echo "kafka cluster stop" ssh Desktop "source /home/appleyuchi/.bashrc;$KAFKA/bin/kafka-server-stop.sh &" ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA2/bin/kafka-server-stop.sh &" ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA3/bin/kafka-server-stop.sh &"

②中腳本運行后，并不會立刻關(guān)閉所有節(jié)點，

需要等待一段時間才能讓所有kafka節(jié)點關(guān)閉。

?

?

注意點

①bash: : comman排查d not found

檢查下腳本中有沒有圓角字符的空格

②Desktop登錄Laptop,

腳本是在Desktop中執(zhí)行的，讀取的是Desktop中的環(huán)境變量

因此雖然$KAFKA2是屬于Laptop的節(jié)點，為了Desktop上腳本順利執(zhí)行，需要在Desktop的~/.bashrc中設(shè)置好$KAFKA2的具體值(這點非常重要，務(wù)必注意)。

否則會導(dǎo)致Reference中各種方案全部失效。

③$KAFKA/bin/kafka-run-class.sh中的開頭加入

export JAVA_HOME="/home/appleyuchi/Java/jdk1.8.0_144"

并且

# Which java to use if [ -z "$JAVA_HOME" ]; thenJAVA="java" elseJAVA="$JAVA_HOME/bin/java" fi

改成

# Which java to use if [ -z "$JAVA_HOME" ]; thenJAVA="$JAVA_HOME/bin/java" elseJAVA="$JAVA_HOME/bin/java" fi

?

排查

如果無法順利啟動的話，

去$KAFKA/logs

下面查看具體的報錯信息。

?

Reference:

[1]啟動kafka集群，關(guān)閉kafka集群腳本(測試失敗)

[2]shell腳本啟動kafka集群(shell腳本啟動kafka集群，先放著再說)

[3]Kafka集群啟動停止腳本(測試失敗)

[4]kafka 集群啟動腳本 xkafka

[5]shell腳本，一次性啟動kafka集群

[6]Kafka集群一鍵啟動腳本

[7][資料] kafka集群設(shè)置shell腳本一鍵啟動經(jīng)驗總結(jié)

[8]kafka集群啟停腳本

[9]shell腳本啟動kafka集群的多臺節(jié)點

[10]【4】Kafka集群啟動/關(guān)閉腳本

[11]一鍵啟動和關(guān)閉zookeeper和kafka集群腳本

[12]集群自動化啟動腳本（kafka，zookeeper，es）

[13]kafka集群啟動腳本

[14]Kafka集群設(shè)置一鍵啟動/一鍵停止腳本

[15]kafka集群開啟及關(guān)閉腳本參考

[16]kafka集群一鍵啟動shell腳本

[17]Kafka 集群啟動關(guān)閉腳本

[18]kafka設(shè)置shell腳本文件一鍵啟動和關(guān)閉

[19]zoookeeper集群和kafka集群啟動快速啟動腳本

[20]kafka深度研究之路(3)-kafka 與zk 集群啟停腳本

[21]kafka批量啟動、關(guān)閉腳本

[22]Linux Shell遠(yuǎn)程執(zhí)行命令(測試失敗)

總結(jié)

以上是生活随笔為你收集整理的kafka一键启动集群的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。