zoukankan      html  css  js  c++  java
  • kafka存活监控脚本

    #!/bin/bash
    #-*- coding: utf-8 -*-
    #Date: 2018/11/20
    #Author: Mr.yang

    KAFKA_HOST="192.168.0.184:9092"   #kafka主机IP+端口
    KAFKA_CMD="/database/kafka/bin/kafka-producer-perf-test.sh"  #kafka脚本执行路径(根据自己本身环境修改,脚本名无需更改)
    PARATER="--num-records 5 --record-size 2 --throughput 10"   #参数,可不修改
    TOPIC_NAME="monitor"   #Topic名称可创建一个测试使用


    ps -ef |grep kafka |grep -v grep |grep -v kafka.sh > /dev/null
    if [ $? -eq 0 ];then
      timeout 10s sh ${KAFKA_CMD} ${PARATER} --topic ${TOPIC_NAME} --producer-props bootstrap.servers=${KAFKA_HOST} > /dev/null
      if [ $? -ne 0 ];then
        echo 1
      else
        echo 0
      fi
      elif [ $? -ne 0 ];then
        echo 1
    fi

  • 相关阅读:
    第四周作业
    第四周上机练习
    第一次作业
    第八周作业
    第八周上机练习
    第七周作业
    第五次上机练习
    第六周作业
    第四次上机练习
    第三次上机练习
  • 原文地址:https://www.cnblogs.com/Huang-Niu/p/9993803.html
Copyright © 2011-2022 走看看