1. #!/bin/sh  
2. #  
3. # chkconfig: 345 99 01  
4. # description: Kafka  
5. #  
6. # File : Kafka  
7. #  
8. # Description: Starts and stops the Kafka server  
9. #  
10.   
11. source /etc/rc.d/init.d/functions  
12.   
13. KAFKA_HOME=/opt/kafka  
14. KAFKA_USER=kafka  
15. # See how we were called.  
16. case "$1" in  
17.   
18.   start)  
19.     echo -n "Starting Kafka:"  
20.     /sbin/runuser $KAFKA_USER -c "nohup $KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties > /var/log/kafka/server.out 2> /var/log/kafka/server.err &"  
21.     echo " done."  
22.     exit 0  
23.     ;;  
24.   
25.   stop)  
26.     echo -n "Stopping Kafka: "  
27.     /sbin/runuser  $KAFKA_USER  -c "ps -ef | grep kafka.Kafka | grep -v grep | awk '{print \$2}' | xargs kill"  
28.     echo " done."  
29.     exit 0  
30.     ;;  
31.   hardstop)  
32.     echo -n "Stopping (hard) Kafka: "  
33.     /sbin/runuser  $KAFKA_USER  -c "ps -ef | grep kafka.Kafka | grep -v grep | awk '{print \$2}' | xargs kill -9"  
34.     echo " done."  
35.     exit 0  
36.     ;;  
37.   
38.   status)  
39.     c_pid=`ps -ef | grep kafka.Kafka | grep -v grep | awk '{print $2}'`  
40.     if [ "$c_pid" = "" ] ; then  
41.       echo "Stopped"  
42.       exit 3  
43.     else  
44.       echo "Running $c_pid"  
45.       exit 0  
46.     fi  
47.     ;;  
48.   
49.   restart)  
50.     stop  
51.     start  
52.     ;;  
53.   
54.   *)  
55.     echo "Usage: cassandra {start|stop|hardstop|status|restart}"  
56.     exit 1  
57.     ;;  
58.   
59. esac