我有一台安装了apachekafka的ubuntu16.04机器。目前,我可以通过使用 start_kafka.sh
包含以下内容的脚本:
JMX_PORT=17264 KAFKA_HEAP_OPTS="-Xms1024M -Xmx3072M" /home/kafka/kafka_2.11-0.10.1.0/bin/kafka-server-start.sh -daemon /home/kafka/kafka_2.11-0.10.1.0/config/server.properties
现在,我想用 supervisor
如果进程失败,则自动重新启动进程,并在重新启动计算机后立即启动。问题是我做不到 supervisor
开始Kafka。
我安装了 supervisor
使用 pip
并将此配置文件放置在 /etc/supervisord.conf
:
; Supervisor config file.
;
; For more information on the config file, please see:
; http://supervisord.org/configuration.html
[unix_http_server]
file=/tmp/supervisor.sock ; (the path to the socket file)
[supervisord]
logfile=/tmp/supervisord.log ; (main log file;default $CWD/supervisord.log)
logfile_maxbytes=50MB ; (max main logfile bytes b4 rotation;default 50MB)
logfile_backups=10 ; (num of main logfile rotation backups;default 10)
loglevel=info ; (log level;default info; others: debug,warn,trace)
pidfile=/tmp/supervisord.pid ; (supervisord pidfile;default supervisord.pid)
nodaemon=false ; (start in foreground if true;default false)
minfds=1024 ; (min. avail startup file descriptors;default 1024)
minprocs=200 ; (min. avail process descriptors;default 200)
; the below section must remain in the config file for RPC
; (supervisorctl/web interface) to work, additional interfaces may be
; added by defining them in separate rpcinterface: sections
[rpcinterface:supervisor]
supervisor.rpcinterface_factory = supervisor.rpcinterface:make_main_rpcinterface
[supervisorctl]
serverurl=unix:///tmp/supervisor.sock ; use a unix:// URL for a unix socket
[program:kafka]
command=/home/kafka/kafka_2.11-0.10.1.0/start_kafka.sh ; the program (relative uses PATH, can take args)
;process_name=%(program_name)s ; process_name expr (default %(program_name)s)
startsecs=10 ; # of secs prog must stay up to be running (def. 1)
startretries=3 ; max # of serial start failures when starting (default 3)
;autorestart=unexpected ; when to restart if exited after running (def: unexpected)
;exitcodes=0,2 ; 'expected' exit codes used with autorestart (default 0,2)
stopsignal=TERM ; signal used to kill process (default TERM)
stopwaitsecs=180 ; max num secs to wait b4 SIGKILL (default 10)
stdout_logfile=NONE ; stdout log path, NONE for none; default AUTO
;environment=A="1",B="2" ; process environment additions (def no adds)
当我尝试启动Kafka时,出现以下错误:
# supervisorctl start kafka
kafka: ERROR (spawn error)
以及主管日志(在 /tmp/supervisord.log
)包含以下内容:
2017-01-23 22:10:24,532 INFO spawned: 'kafka' with pid 21311
2017-01-23 22:10:24,536 INFO exited: kafka (exit status 127; not expected)
2017-01-23 22:10:25,542 INFO spawned: 'kafka' with pid 21312
2017-01-23 22:10:25,559 INFO exited: kafka (exit status 127; not expected)
2017-01-23 22:10:27,562 INFO spawned: 'kafka' with pid 21313
2017-01-23 22:10:27,567 INFO exited: kafka (exit status 127; not expected)
2017-01-23 22:10:30,571 INFO spawned: 'kafka' with pid 21314
2017-01-23 22:10:30,576 INFO exited: kafka (exit status 127; not expected)
2017-01-23 22:10:31,578 INFO gave up: kafka entered FATAL state, too many start retries too quickly
必须说,我已经试着把 -daemon
标志进入 start_kafka.sh
与…一起使用 supervisor
但没有成功。
有人知道发生了什么事吗?
2条答案
按热度按时间8yoxcaq71#
下面的supervisor配置文件适用于我,来自https://github.com/miguno/wirbelsturm 通过https://github.com/miguno/puppet-kafka. 主要区别在于它使用
kafka-run-class.sh
而不是kafka-server-start.sh
.请注意,您需要更新各种路径,使其与您的设置相匹配,例如,您必须更改
/opt/kafka/bin/kafka-run-class.sh
至/home/kafka/kafka_2.11-0.10.1.0/bin/kafka-run-class.sh
.9rnv2umw2#
我最终设法让主管与Kafka合作,做了两个改变:
部署Kafka
-daemon
标志,因为主管需要非后台进程来管理在supervisor配置文件中显式定义java路径
这是工作配置:
启动\u kafka.sh
监理人.conf