启动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/bin
case $1 in
"start")
{
for i in node1 node2 node3
do
echo "---------- 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 node3
do
echo "---------- 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
再次尝试通过脚本启动
发现可以成功启动。