美文网首页
黑猴子的家:kafka.sh new version

黑猴子的家:kafka.sh new version

作者: 黑猴子的家 | 来源:发表于2022-05-05 16:25 被阅读0次
[alex@hadoop102 ~]$ cd /usr/local/bin/
[alex@hadoop102 bin]$ sudo touch kafka.sh
[alex@hadoop102 bin]$ sudo chown alex:alex kafka.sh 
[alex@hadoop102 bin]$ chmod 755 kafka.sh 
[alex@hadoop102 bin]$ vim kafka.sh
#!/bin/bash

user=`whoami`
kafka_home=/opt/module/kafka_2.11-0.11.0.2

case $1 in
    start)
        for((host=102; host<=104; host++)); do
            echo -e "---启动 $user@hadoop$host kafka---"
            ssh $user@hadoop$host "source /etc/profile; export JMX_PORT=9999 && $kafka_home/bin/kafka-server-start.sh -daemon $kafka_home/config/server.properties"
        done
    ;;
    stop)
        for((host=102; host<=104; host++))
        do
            # 睡3秒钟
            sleep 3
            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 &"
        done
    ;;
    *)
        echo "你启动的姿势不对"
        echo "  start   启动kafka集群"
        echo "  stop    停止kafka集群"
    ;;
esac

相关文章

网友评论

      本文标题:黑猴子的家:kafka.sh new version

      本文链接:https://www.haomeiwen.com/subject/ewzvertx.html