很多小伙伴可能知道 kafka 这个中间件,然后自己也想搭建下,那么我们现在从零基础开始整合 SpringBoot 来搭建下吧。写的有问题的地方请多多指教哈 「前言」在我们要搞这个 Demo 的前提下,我们要搭建下环境
- 搭建 ZooKeeper,因为 Kafka 就是强依赖于 ZooKeeper,没有 ZooKeeper 的话 Kafka
都无法运行。 ZooKeeper 为 Kafka 提供了元数据的管理,例如一些Broker 的信息、主题数据、分区数据等等 - 搭建 Kafka 集群
- 搭建集群之后,我们创建一个基于 SpringBoot 的 Maven 项目哈
- 写代码调试 代码在这里「GitHub」
接下来让我们一起搭建 Zookeeper 吧
1 首先下载zookeeper apache zookeeper官网 :https://zookeeper.apache.org/ apache zookeeper下载地址 :https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/ 看好了,是下载这个「bin.tar.gz」后缀名的文件这里我们以苹果笔记本的系统为例,因为它更近似 Linux 的系统 1.1解压软件
tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz
1.2 将zookeeper复制三份,分别命名为zookeeper-1,zookeeper-2,zookeeper-3 1.3 将zookeeper-1中的zoo.example.cfg文件复制一份改名为: zoo.cfg **备注:**修改config/zoo.cfg文件「datalog这个文件夹是没有的,手动自己创建下」 这是第二个文件的配置「dataDir位置看好了,自己电脑文件的位置」
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/Users/myh/soft-learn/zookeeper-2/datalog
clientPort=2182
server.1=localhost:2887:3887
server.2=0.0.0.0:2888:3888
server.3=localhost:2889:3889
这是第三个文件内容
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/Users/myh/soft-learn/zookeeper-3/datalog
clientPort=2183
server.1=localhost:2887:3887
server.2=localhost:2888:3888
server.3=0.0.0.0:2889:3889
上面说的那个「datalog」文件夹创建好,然后再做下面这一步
分别-- 在datalog目录下 -- 执行以下命令,写入myid。
创建的时候看着点,看着点,看着点,这个路径
/Users/myh/soft-learn/ 是你自己电脑的路径,别抄我这个
echo "1" > /Users/myh/soft-learn/zookeeper-1/datalog/myid
echo "2" > /Users/myh/soft-learn/zookeeper-2/datalog/myid
echo "3" > /Users/myh/soft-learn/zookeeper-3/datalog/myid
最后分别启动zookeeper集群
/Users/myh/soft-learn/zookeeper-1/bin/zkServer.sh start
/Users/myh/soft-learn/ zookeeper-2/bin/zkServer.sh start
/Users/myh/soft-learn/ zookeeper-3/bin/zkServer.sh start
别着急看下面,把这三个命令都执行完,三个Zookeeper 都启动起来之后再往下看 每一个执行都要看到这个哈,如果已经启动了,先用 PS 命令查看进行编号,然后用 kill 命令杀掉这个进程 使用如下命令判断是否启动成功
/Users/myh/soft-learn/ zookeeper-1/bin/zkServer.sh status
/Users/myh/soft-learn/ zookeeper-2/bin/zkServer.sh status
/Users/myh/soft-learn/ zookeeper-3/bin/zkServer.sh status
执行玩上面的命令应该可以看到线面红色框的信息,这样 Zookeeper 搭建成功了。 想看 Kafka 集群搭建的步骤看下一篇文章
|