1.脚本命令

vim xcallkafka.sh

#!/bin/bash
# 获取控制台指令
cmd=$*

# 判断指令是否为空
if [ ! -n "$cmd" ]
then
    echo "command can not be null!"
    exit
fi

# 获取当前登录用户
user=`whoami`

# 在从机执行命令，需要根据具体集群情况配置
hosts=(master slave1 slave2)

case $1 in
"start"){

for host in ${hosts[@]}
do
    echo "======current host is $host======"
    ssh $user@$host "sh /home/kafka/kafka_2.11-0.11.0.2/bin/kafka-server-start.sh -daemon /home/kafka/kafka_2.11-0.11.0.2/config/server.properties"
done
};;

"stop"){

for host in ${hosts[@]}
do
    echo "======current host is $host======"
    ssh $user@$host "sh /home/kafka/kafka_2.11-0.11.0.2/bin/kafka-server-stop.sh"
done
};;

esac
echo "execute successfully !"

 修改权限：

chmod 777 xcallkafka.sh

2.查看环境

由于使用的是后台模式，所以没有任何输出，使用jps可以看见kafka的进程