黑猴子的家：xkafka.sh

#!/bin/bash

user=`whoami`
kafka_home='/opt/module/kafka-3.2.1'

case $1 in
    "start")
        for((host=102; host<=104; host++)); do
            echo -e "---启动 ${user}@hadoop${host} kafka---"
            ssh ${user}@hadoop${host} "source /etc/profile; ${kafka_home}/bin/kafka-server-start.sh -daemon ${kafka_home}/config/server.properties"
        done
    ;;
    "stop")
        for((host=102; host<=104; host++)); do
            echo -e "---关闭 ${user}@hadoop${host} kafka---"
            ssh ${user}@hadoop${host} "source /etc/profile; nohup ${kafka_home}/bin/kafka-server-stop.sh ${kafka_home}/config/server.properties > /dev/null 2>&1 &"
            # 睡5秒钟
            sleep 5
        done
    ;;
    *)
        echo "你启动的姿势不对"
        echo "start 启动kafka集群"
        echo "stop  停止kafka集群"
    ;;
esac