1 files changed, 42 insertions, 0 deletions
diff --git a/parcels/roles/components/kafka/templates/keepkafalive.j2 b/parcels/roles/components/kafka/templates/keepkafalive.j2
new file mode 100755
index 0000000..2e2f144
--- /dev/null
+++ b/parcels/roles/components/kafka/templates/keepkafalive.j2
@@ -0,0 +1,42 @@
+#!/bin/bash
+# 
+# netconsole    This loads the netconsole module with the configured parameters.
+#
+# chkconfig:123456 30 70
+# description: keepkafkaalive
+source /etc/profile
+PRO_NAME=keepkafkaalive
+
+case $1 in
+start)
+keepnum=`ps -ef | grep dae-kafka.sh | grep -v grep | wc -l`
+
+if [ $keepnum -eq "0" ];then
+nohup {{ install_path }}/{{ kafka_version }}/bin/dae-kafka.sh > /dev/null 2>&1 &
+fi
+;;
+
+stop)
+keeppid=`ps -ef | grep dae-kafka.sh | grep -v grep | awk '{print $2}'`
+if [ $keeppid ];then
+echo "守护进程PID：$keeppid"
+kill -9 $keeppid
+sleep 1
+sh {{ install_path }}/{{ kafka_version }}/bin/kafka-server-stop.sh
+fi
+;;
+
+status)
+num=`jps | grep -w Kafka | grep -v grep |wc -l`
+if [ "$num" -eq "1" ];then
+echo "kafka进程已启动"
+else
+echo "kafka进程未启动"
+fi
+;;
+
+* )
+echo "use keepkafkaalive [start|stop|status]"
+;;
+esac
+