黑猴子的家:kafka.sh new version

[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
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容