安装zookeeper 和 kafka

本文用到的同步脚本 https://www.cnblogs.com/sdgtxuyong/p/16907986.html

一、安装zookeeper

修改hosts文件，将test1，test2，test3，用ip来对应。

下载解压 zookeeper 3.5.7，至/opt/module 目录

在conf目录，拷贝 zoo.sample.cfg ,改名为 zoo.cfg

修改 zoo.cfg

dataDir=/opt/module/zookeeper-3.5.7/zkData # 此文件夹，需提前创建

# 在配置文件最尾，加入这3行，代表是个集群的配置

server.1=test1:2888:3888
server.2=test2:2888:3888
server.3=test3:2888:3888

在zkData 目录下建立 myid 文件，里面填入数字 1，（根据各个服务器名字不同，分别为 2.3）此处不能有空格，顶格写，不能有多余字符。

在/opt/module 下编写脚本 vim zk.sh，并修改权限

case $1 in

"start"){

   for i in test1 test2 test3

   do

      echo ----------------   zookeeper  $i 启动    -----------------

       ssh $i "/opt/module/zookeeper-3.5.7/bin/zkServer.sh start"

   done

}

;;

"stop"){

        for i in test1 test2 test3

   do

      echo --------------- zookeeper $i 停止  ------------------------

       ssh $i "/opt/module/zookeeper-3.5.7/bin/zkServer.sh stop"

   done

}

;;

"status"){

        for i in test1 test2 test3

   do

       echo --------------- zookeeper $i  状态   -------------------

       ssh $i "/opt/module/zookeeper-3.5.7/bin/zkServer.sh status"

   done

}

;;

esac

用同步xsync软件，同步到其他计算，需要改myid的值。

二、安装 kafka 3.0.1 kafka_2.12-3.0.1.tgz

解压kafka 至 /opt/module/ 下

修改 conf/server.properties，共3个地方

broker.id=1

log.dirs=/opt/module/kafka/datas

zookeeper.connect=test1:2181,test2:2181,test3:2181

用同步脚本，xsync至其他计算机，改broker.id 为具体每个计算名。

编写 kf.sh，并增加权限

#!/bin/bash

case $1 in

"start")

        for i in test1 test2 test3

        do

                echo "---------------- 启动 $i kafka  -----------------------"

                ssh $i "/opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/config/server.properties"

        done

;;

"stop")

        for i in test1 test2 test3

        do

                echo "---------------- 停止 $i kafka  -----------------------"

                ssh $i "/opt/module/kafka/bin/kafka-server-stop.sh"

        done

;;

esac

巴特西

安装zookeeper 和 kafka

最新文章

热门文章