在設置kafka停止任務的時候需要注意修改配置文件

在kafka和zookeeper各自組件的bin下邊配置文件

首先設置kafka的啟停配置，在kafka的bin目錄下 vim?start-kafka.sh 啟動配置? vim?stop-kafka.sh 停止配置，具體配置如下：

?

start-kafka.sh

#!/bin/bash for I in {hadoop,hadoop2,hadoop3} do echo "$I 上的kafka 正在啟動" ssh root@$I "source /etc/profile; /root/Downloads/kafka/bin/kafka-server-start.sh -daemon /root/Downloads/kafka/config/server.properties" echo "$I 上的kafka 啟動完成" done

?

stop-kafka.sh

#!/bin/bash for I in {hadoop,hadoop2,hadoop3} do echo "$I 上的kafka 正在關閉" ssh root@$I "source /etc/profile; /root/Downloads/kafka/bin/kafka-server-stop.sh" echo "$I 上的kafka 關閉完成" done

官方提供的stop文件命令不好使，需要修改stop腳本，集群中的機器都需要改

修改bin目錄下的kafka-server-stop.sh 文件

PIDS=$(ps ax?|?grep?-i?'kafka\.Kafka'?|?grep java?|?grep?-v?grep?|?awk?'{print $1}')

修改后：

PIDS=$(jps -lm?|?grep?-i?'kafka\.Kafka'?|?awk?'{print $1}')

下面是設置zookeeper的配置文件：

?

start-zk.sh

#!/bin/bash for I in {hadoop,hadoop2,hadoop3} do echo "$I 上的kafka 正在關閉" ssh root@$I "source /etc/profile; /root/Downloads/zookeeper/bin/zkServer.sh start" echo "$I 上的kafka 關閉完成" done

stop-zk.sh

#!/bin/bash for I in {hadoop,hadoop2,hadoop3} do echo "$I 上的kafka 正在關閉" ssh root@$I "source /etc/profile; /root/Downloads/zookeeper/bin/zkServer.sh stop" echo "$I 上的kafka 關閉完成" done

修改完以后放到各自的bin目錄下，最后運行的時候要給腳本賦個權限:

chmod +x ?XXX.sh 或者 chmod -R 777 XXX.sh

總結

以上是生活随笔為你收集整理的kafka和zookeeper一键启停脚本（以及kafka关不掉问题解决）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。