以下是我如何配置Kafka在Ubuntu 14.04上自动启动:
sudo su cp -R ~/kafka_2.11-0.10.0.1 /opt ln -s /opt/kafka_2.11-0.10.0.1 /opt/kafka
将以下init脚本复制到/etc/init.d/kafka:
DAEMON_PATH=/opt/kafka/ PATH=$PATH:$DAEMON_PATH/bin # See how we were called. case "$1" in start) # Start daemon. echo "Starting Zookeeper"; nohup $DAEMON_PATH/bin/zookeeper-server-start.sh -daemon /$DAEMON_PATH/config/zookeeper.properties 2> /dev/null && \ echo "Starting Kafka"; nohup $DAEMON_PATH/bin/kafka-server-start.sh -daemon /$DAEMON_PATH/config/server.properties 2> /dev/null ;; stop) # Stop daemons. echo "Shutting down Zookeeper"; pid=`ps ax | grep -i 'org.apache.zookeeper.server' | grep -v grep | awk '{print $1}'` if [ -n "$pid" ] then kill -9 $pid else echo "Zookeeper was not Running" fi echo "Shutting down Kafka"; pid=`ps ax | grep -i 'kafka.Kafka' | grep -v grep | awk '{print $1}'` if [ -n "$pid" ] then kill -9 $pid else echo "Kafka was not Running" fi ;; restart) $0 stop sleep 2 $0 start ;; status) pid=`ps ax | grep -i 'org.apache.zookeeper.server' | grep -v grep | awk '{print $1}'` if [ -n "$pid" ] then echo "Zookeeper is Running as PID: $pid" else echo "Zookeeper is not Running" fi pid=`ps ax | grep -i 'kafka.Kafka' | grep -v grep | awk '{print $1}'` if [ -n "$pid" ] then echo "Kafka is Running as PID: $pid" else echo "Kafka is not Running" fi ;; *) echo "Usage: $0 {start|stop|restart|status}" exit 1 esac exit 0
使用以下命令创建kafka服务:
chmod 755 /etc/init.d/kafka update-rc.d kafka defaults
现在您应该可以像这样启动和停止kafka服务:
sudo service kafka start sudo service kafka status sudo service kafka stop
如果您想稍后删除Kafka服务,请运行 update-rc.d -f kafka remove 。
update-rc.d -f kafka remove
一种简单的方法是使用systemd。你应该注意在启动时环境变量如 JAVA_HOME 还没有加载,所以我们应该将它们引入系统。一个好的解决方案是创建一个名为的文件 profile 并添加所有必要的变量:
profile
# /home/kafka/profile JAVA_HOME=/opt/jdk8 KAFKA_HOME=/opt/kafka
假设你已经在路径上安装了Kafka /opt/kafka ,为了让Kafka在Ubuntu启动后自动运行(在Ubuntu 16.04和centOS7上测试,我猜它可以在systemd支持的任何发行版上工作)执行以下命令:
/opt/kafka
sudo nano /etc/systemd/system/kafka.service # open file to add service informations
现在将以下内容添加到该文件中
[Unit] Description=Kafka Daemon Wants=syslog.target # suppose you have a service named zookeeper that it start zookeeper and we want Kafka service run after the zookeeper service After=zookeeper.service [Service] Type=forking # the user whom you want run the Kafka start and stop command under User=kafka # the file path that contains envirnment variables EnvironmentFile=/home/kafka/profile # the directory that the commands will run there WorkingDirectory=/home/kafka/ # Kafka server start command ExecStart=/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties # Kafka server stop command ExecStop=/opt/kafka/bin/kafka-server-stop.sh -daemon TimeoutSec=30 Restart=on-failure [Install] WantedBy=multi-user.target
的 注意: 强> 由于Kafka需要动物园管理员在开始时连接它,我想我们也有一个zookeeper服务,我设置Kafka服务在zookeeper服务启动后运行。
现在保存后 kafka.service 文件,只需运行以下命令即可创建Kafka服务的链接,每次重启操作系统时都会启动它:
kafka.service
sudo systemctl enable kafka
现在,您可以使用以下命令启动Kafka服务:
sudo systemctl start kafka.service
并检查服务的状态:
sudo systemctl status kafka.service