有问题的地方望指出。

---

         （零）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,也没什么问题，至此，算是结束了。

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

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

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

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

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

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