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