zoukankan      html  css  js  c++  java
  • 【4】Kafka集群启动/关闭脚本

    说明:本脚本基于SSH服务器免密登录,如集群未配置SSH,参照:《SSH安装配置》 。

    一、启动脚本:start-kafka-cluster.sh

    #!/bin/bash
    brokers="server1 server2 server3"
    KAFKA_HOME="/usr/local/services/kafka/kafka_2.11-2.3.0"
    KAFKA_NAME="kafka_2.11-2.3.0"
    
    echo "INFO : Begin to start kafka cluster ..."
    
    for broker in $brokers
    do
      echo "INFO : Starting ${KAFKA_NAME} on ${broker} ..."
      ssh ${broker} -C "source /etc/profile; sh ${KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties"
      if [[ $? -eq 0 ]]; then
          echo "INFO:[${broker}] Start successfully"
      fi
    done
    echo "INFO:Kafka cluster starts successfully !"
    

    为脚本添加执行权限:

    chmod a+x start-kafka-cluster.sh
    

    二、停止脚本:stop-kafka-cluster.sh

    #!/bin/bash
    brokers="server1 server2 server3"
    KAFKA_HOME="/usr/local/services/kafka/kafka_2.11-2.3.0"
    KAFKA_NAME="kafka_2.11-2.3.0"
    
    echo "INFO : Begin to stop kafka cluster ..."
    
    for broker in $brokers
    do
      echo "INFO : Shut down ${KAFKA_NAME} on ${broker} ..."
      ssh ${broker} "source /etc/profile;bash ${KAFKA_HOME}/bin/kafka-server-stop.sh"
      if [[ $? -ne 0 ]]; then
          echo "INFO : Shut down ${KAFKA_NAME} on ${broker} is down"
      fi
    done
    
    echo "INFO : kafka cluster shut down completed!"
    

    为脚本添加执行权限:

    chmod a+x stop-kafka-cluster.sh
    

    参考资料

    参考书籍:Kafka入门与实践

  • 作者: DeepInThought
    出处: https://www.cnblogs.com/DeepInThought
    本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。
查看全文
  • 相关阅读:
    JAVA 遍历UFT-8所有中文
    用友U8 | 【固定资产】固定资产常见问题
    用友U8 | 【出纳管理】当前凭证不是出纳管理凭证,不能修改
    用友U8 | 【出纳管理】选中的日记账包含了已制单但没有回写凭证号的日记账,无法制单!
    用友U8 | 【生产订单】工作日历未设定或超出工作日历范围
    用友U8 | 【出纳管理】当前选择的日记账已经制单,上次制单包含其他账户的日记账,请在日记账查询中修改
    用友U8 | 【U8年结】开账结转如何操作?
    用友U8 | 【出纳管理】收支操作生单提示:集合中的143272已经加锁了,不能对集合中的数据进行加锁
    用友U8 | 【出纳管理】银行记账提示:未设置对象变量或with block 变量(91)
    MySQL经典45题(二)
  • 原文地址:https://www.cnblogs.com/DeepInThought/p/11143981.html
  • Copyright © 2011-2022 走看看