mysql+canal+kafka+elasticsearch构

上面提到了如何搭建canal。本篇文章会简单介绍如何搭建zookeeper的环境

zookeeper介绍:

ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，它是集群的管理者，监视着集群中各个节点的状态根据节点提交的反馈进行下一步合理操作。最终，将简单易用的接口和性能高效、功能稳定的系统提供给用户

关于zk的学习，推荐一本书（从Paxos到Zookeeper 分布式一致性原理与实践）：

链接: https://pan.baidu.com/s/1hygqnu8xyqdARjKUb90MwA

提取码: wh8s 

zookeeper在这里作为kafka的安装先行条件

首先安装brew(安装包):

这个是相关简介和安装教程

https://www.cnblogs.com/xd502djj/p/6923690.html

然后通过brew安装依赖环境

brew install zookeeper

brew install kafka

zookeeper相关安装目录:

zookeeper配置文件位置：

要搭建zookeeper伪集群环境。要准备3个配置文件

也就是zoo.cfg拷贝两份，然后改动具体文件内容：

相关改动如下，定义数据日志地址。端口，通信地址。下面是zoo.cfg

zoo1.cfg：

zoo2.cfg：

另外一个关键步骤:

在每个关键的数据目录中。要建立一个myid，myid内容如图所示:

相关编号

其他伪分布式节点类似。myid分别为2和3

那么最后我们来看zookeeper的启动，下面是启动命令:

 zkServer start  /usr/local/etc/zookeeper/zoo.cfg

 zkServer start /usr/local/etc/zookeeper/zoo1.cfg

 zkServer start /usr/local/etc/zookeeper/zoo2.cfg 

zookeeper停止命令:

zkServer stop  /usr/local/etc/zookeeper/zoo.cfg

zkServer stop /usr/local/etc/zookeeper/zoo1.cfg

 zkServer stop /usr/local/etc/zookeeper/zoo2.cfg 

启动完成后，我们通过jps命令查看相关进程是否启动完成:

通过zk自带命令行查看是否启动完成:

第一个节点:

zkCli。默认连接2181端口

第二个节点：

zkCli -server localhost:2182

第三个节点 ：

zkCli -server localhost:2183

这样我们的伪分布式zk集群搭建完成