啟動Kafka集群時,需要在每臺個節點上啟動啟動服務,比較麻煩,通過寫了以下腳本來進行啟停;發現能正常使用停止功能,不能正常啟動Kafka;
Kafka啟停腳本:
## 以防不能通過shell腳本啟動Kafka服務
## 先在~/.bashrc文下配置JAVA_HOME
## 如果已經安裝了jdk,通過which Java 命令可以查看jdk的安裝位置
## export JAVA_HOME=/export/server/jdk1.8.0_131
## export PATH=$PATH:$JAVA_HOME/bincase $1 in
"start"){for i in node1 node2 node3doecho "---------- kafka $i 啟動 ------------"ssh $i "/export/server/kafka/bin/kafka-server-start.sh -daemon /export/server/kafka/config/server.properties"done
};;
"stop"){for i in node1 node2 node3doecho "---------- kafka $i 停止 ------------"ssh $i "/export/server/kafka/bin/kafka-server-stop.sh "done
};;
esac
解決辦法:
#先在~/.bashrc文下配置JAVA_HOME,已經安裝jdk的,通過which Java 命令可以查看jdk的安裝位置
vim ~/.bashrc
#export JAVA_HOME=/export/server/jdk1.8.0_131
#export PATH=$PATH:$JAVA_HOME/bin
再次嘗試通過腳本啟動
發現可以成功啟動。