使用Supervisor 管理 kafka及zookeeper

kafka.ini配置文件

[root@node1 supervisor]# cat /etc/supervisor/conf.d/kafka.ini 
[program:kafka]
command=/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties
autostart=true
autorestart=true
startsecs=3
redirect_stderr=true
stdout_logfile=/var/log/supervisor/kafka
stderr_logfile=/var/log/supervisor/kafka_error
stdout_logfile_maxbytes=0

zookeeper.ini配置文件

[root@node1 supervisor]# cat /etc/supervisor/conf.d/zookeeper.ini 
[program:zookeeper]
command=/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties
autostart=true
autorestart=true
startsecs=3
redirect_stderr=true
stdout_logfile=/var/log/supervisor/zookeeper
stderr_logfile=/var/log/supervisor/zookeeper_error
stdout_logfile_maxbytes=0

快速执行

#如果你的安装目录是和我的一致,那么直接用下面的几条命令直接执行就可以
[root@node2 ~]# curl -s http://download.baiyongjie.com/linux/supervisord/conf.d/kafka.ini > /etc/supervisor/conf.d/kafka.ini
[root@node2 ~]# curl -s http://download.baiyongjie.com/linux/supervisord/conf.d/zookeeper.ini > /etc/supervisor/conf.d/zookeeper.ini

[root@node2 ~]# supervisorctl  reread
kafka: available
zookeeper: available

[root@node2 ~]# supervisorctl  update
kafka: added process group
zookeeper: added process group

[root@node2 ~]# netstat -nplt|grep java
tcp6       0      0 10.241.0.11:3888        :::*                    LISTEN      2245/java
tcp6       0      0 :::42329                :::*                    LISTEN      2967/java
tcp6       0      0 :::38210                :::*                    LISTEN      2245/java
tcp6       0      0 :::9092                 :::*                    LISTEN      2967/java
tcp6       0      0 :::2181                 :::*                    LISTEN      2245/java
tcp6       0      0 10.241.0.11:2888        :::*                    LISTEN      2245/java