kafka 版本 kafka_2.11-0.10.2.1

因為kafka沒有批量啟動指令碼，每次都需要在各個broker節點上啟動kafka服務。比較麻煩。

這裡自定義一個kafka啟動的指令碼：

#!/bin/bash
 
BROKERS="hdp-01 hdp-02 hdp-03"
 
KAFKA_HOME="/root/apps/kafka_2.11-0.10.2.1"
 
for broker in $BROKERS
 
do
 
        echo "INFO:starting kafka server on ${broker}"
 
        ssh $broker  "source /etc/profile;${KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAF
KA_HOME}/config/server.properties & "
 
        if [ $? != 0 ];
 
        then
 
                echo "Can not starting kafka server on host ${broker}";
 
                exit 1;
 
        fi
 
done
 

思路：

設定brokers和 kafka的安裝目錄，備用。

迴圈執行啟動kafka的程序。 使用—daemon指定後臺啟動。

並新增一些輸出日誌。

自定義kafka一鍵停止指令碼：

#!/bin/bash
 
BROKERS="hdp-01 hdp-02 hdp-03"
 
KAFKA_HOME="/root/apps/kafka_2.11-0.10.2.1"
 
for broker in $BROKERS
 
do
 
        echo "INFO:stopping kafka server on ${broker}"
 
        ssh $broker "source /etc/profile;${KAFKA_HOME}/bin/kafka-server-stop.sh"
 
        if [ $? != 0 ];
 
        then
 
                echo "Can not stopping kafka server on host ${broker}"
 
                exit 1
 
        fi
 
done 
 

當前版本下，如果想使用kafka的停止命令，需要修改停止指令碼檔案：

修改kafka-server-stop.sh檔案，去除一部分的過濾條件。之後停止指令碼及一鍵停止的指令碼才能正常執行。

注意事項：

1，本次測試的3臺機器主機名分別是hdp-01,hdp-02和 hdp-03。 然後hdp-01到hdp-02和hdp-01到hdp-03的單向免密登入是通的。否則就需要先進行免密登入配置。（因為沒有全部配通免密登入，所有啟動命令只能在hdp-01上執行即可，如果想在任意一臺機器上都能執行，那麼就需要配置所有的免密登入）

2，在ssh 遠端啟動指令碼中，先執行了 source /etc/profile，重新載入了系統環境變數。目的是為了把jdk的命令載入到當前系統環境中，否則報錯。

報錯如下：

nohup: failed to run command `java': No such file or directory
--------------------- 

原文：https://blog.csdn.net/qq_21439395/article/details/80871449