Kafka、zookeeper、kafka-manager 开机自启 --- kafka集群搭建

2022-09-08 09:19:22

有问题的地方望指出。

（零）linux 从零开始搭建虚拟机集群，安装jdk，ssh免密登录 -- 小白教程

（一）环境介绍及所需安装包下载 --- kafka集群搭建

（二）搭建zookeeper集群 --- kafka集群搭建

（三）搭建kafka 集群 --- kafka集群搭建

（四）Kafka-manager 可视化web界面搭建--- kafka集群搭建

（五）Kafka、zookeeper、kafka-manager 开机自启 --- kafka集群搭建

1.zookeeper 开机自启。

切换到 /etc/rc.d/init.d 目录下.
cd /etc/rc.d/init.d/
编辑 zookeeper 文件。
vi zookeeper # 会自动创建的
ps：这里/usr/local/zookeeper/bin 就是zookeeper 所在位置。
/usr/java/latest 是 jdk 所在位置。
ps：查看jdk 所在位置：
echo $JAVA_HOME # 前提是赔了jdk环境变量
添加内容：
#!/bin/bash

#chkconfig:2345 20 90

#description:zookeeper

#processname:zookeeper

export JAVA_HOME=/usr/java/latest

case $1 in

          start) su root /usr/local/zookeeper/bin/zkServer.sh start;;

          stop) su root /usr/local/zookeeper/bin/zkServer.sh stop;;

          status) su root /usr/local/zookeeper/bin/zkServer.sh status;;

          restart) su root /usr/local/zookeeper/bin/zkServer.sh restart;;

     *)  echo "require start|stop|status|restart"  ;;

esac
然后，保存退出。
为 zookeeper 赋予权限。
chmod +x zookeeper
使用 service 来操作 zookeepe：
service zookeeper status # 查看状态
service zookeeper start # 启动
service zookeeper stop # 停止
设置开机自启。开机启动里面添加 zookeeper：
chkconfig --add zookeeper
确认 zookeeper 是否成功添加：
chkconfig --list
ok,没问题，我们重新启动一下虚拟机命令：reboot再来查看：
Ok，也没什么问题，并且已经添加到 zookeeper 集群中。

2.kafka 开机自启。

进入目录 init.d
cd /etc/init.d
编辑 kafka 添加内容。
vi kafka
添加内容：
#!/bin/bash

export JAVA_HOME=/usr/java/latest

export PATH=$JAVA_HOME/bin:$PATH



#chkconfig:2345 20 90

#description:kafka

#processname:kafka

case $1 in

          start)

              /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

              ;;

          stop)

               /usr/local/kafka/bin/kafka-server-stop.sh

              ;;

          status)

              jps

              ;;

          restart)

              /usr/local/kafka/bin/kafka-server-stop.sh

              /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

              ;;

          *)

              echo "require start|stop|status|restart"

              ;;

esac
Ok,java 路径和上面一样，保存退出。
修改 kafka 权限。
chmod 755 kafka
测试。
service kafka status
service kafka stop
service kafka start
添加到服务列表
chkconfig --add kafka
验证：
chkconfig --list
设置为开机启动
chkconfig kafka on
Ok， kafka 开启自启没什么问题。这里重新启动的时候，如果kafka先启动会有一个等待连接时间，这段时间已经足够zookeeper 启动。

3.kafka-manager 开机自启。

进入目录

cd /etc/init.d/

编辑 kafka-manager

vi kafka-manager

添加内容：

#!/bin/bash

export JAVA_HOME=/usr/java/latest

export PATH=$JAVA_HOME/bin:$PATH



#chkconfig:2345 20 90

#description:kafka-manager

#processname:kafka-manager

case $1 in

          start)

              nohup /usr/local/kafka-manager/bin/kafka-manager -Dconfig.file=/usr/local/kafka-manager/conf/application.conf -Dhttp.port=8888 >/usr/local/kafka-manager/kafka-manager.log 2>&1 &

              ;;

          status)

              jps

              ;;

          *)

              echo "require start|status"

              ;;

esac

执行命令;

chmod 755 kafka-manager

查看状态：

service kafka-manager status

添加到服务：

chkconfig --add kafka-manager

检查：

chkconfig --list

开启：

chkconfig kafka on

重启查看：

reboot

Ok,也没什么问题，至此，算是结束了。