目标：

step1：如何启动Kafka集群？
step2：如何关闭Kafka集群？
step3：如何封装启动及关闭脚本？

实施：

• 启动Zookeeper命令

  /export/server/zookeeper-3.4.6/bin/start-zk-all.sh 
  

• 启动Kafka命令

  bin/kafka-server-start.sh config/server.properties >>/dev/null 2>&1 &
  

  • ‘>>/dev/null 2>&1 &’：意思为在后台运行

• 关闭Kafka命令

  bin/kafka-server-stop.sh 
  

• 封装Kafka脚本

  • 启动脚本

    #进入脚本
    vim /export/server/kafka_2.12-2.4.1/bin/start-kafka.sh
    
    #!/bin/bash
    KAFKA_HOME=/export/server/kafka_2.12-2.4.1
    for number in {1..3}
    do
            host=node${number}
            echo ${host}
            /usr/bin/ssh ${host} "cd ${KAFKA_HOME};source /etc/profile;export JMX_PORT=9988;${KAFKA_HOME}/bin/kafka-server-start.sh ${KAFKA_HOME}/config/server.properties >>/dev/null 2>&1 &"
            echo "${host} started"
    done
    
    #更改权限
    chmod u+x /export/server/kafka_2.12-2.4.1/bin/start-kafka.sh
    

  • 关闭脚本

    #进入脚本
    vim /export/server/kafka_2.12-2.4.1/bin/stop-kafka.sh
    
    #!/bin/bash
    KAFKA_HOME=/export/server/kafka_2.12-2.4.1
    for number in {1..3}
    do
      host=node${number}
      echo ${host}
      /usr/bin/ssh ${host} "cd ${KAFKA_HOME};source /etc/profile;${KAFKA_HOME}/bin/kafka-server-stop.sh"
      echo "${host} stoped"
    done
    
    #更改权限
    chmod u+x /export/server/kafka_2.12-2.4.1/bin/stop-kafka.sh