linux 源码搭建Kafka集群,100%有效 (2)

在这里插入图片描述

添加myid文件

说明:除了修改 zoo.cfg 配置文件,集群模式下还要新增一个名叫myid的文件,这个文件放在上述dataDir指定的目录下,这个文件里面就只有一个数据,就是上图配置中server.x的这个x(1,2,3)值,zookeeper启动时会读取这个文件,拿到里面的数据与 zoo.cfg 里面的配置信息比较从而判断到底是那个server(节点)。

cd /usr/local/zookeeper/data vi myid

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-7JJoAxgE-1629162748604)(kafka%E6%BA%90%E7%A0%81%E7%BC%96%E8%AF%91%E5%AE%89%E8%A3%85.assets/image-20210806213748986.png)]


将配置好的zookeeper 复制到其他集群节点上

scp -r /usr/local/zookeeper/ root@192.168.xxx.xxx:/usr/local/zookeeper scp -r /usr/local/zookeeper/ root@192.168.xxx.xxx:/usr/local/zookeeper scp -r /usr/local/zookeeper/ root@192.168.xxx.xxx:/usr/local/zookeeper ##复制安装完成的java 到其它集群节点(如已完成JDK安装请忽略) scp -r /usr/local/java/ root@192.168.xxx.xxx:/usr/local/java scp -r /usr/local/java/ root@192.168.xxx.xxx:/usr/local/java scp -r /usr/local/java/ root@192.168.xxx.xxx:/usr/local/java ## 配置其它集群节点java环境变量 vi /etc/profile export JAVA_HOME=http://www.likecs.com/usr/local/java export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar export PATH=$PATH:$JAVA_HOME/bin

注:分别修改服务节点的myid 值(与上述server所对应服务器一致如:server.1=192.168.238.128则对应服务器的myid为1以次类推)

vi /usr/local/zookeeper/data/myid ## 所有机器 启动节点(所有机器执行下述操作) cd /usr/local/zookeeper/bin

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-WuEQ7ICB-1629162748605)(kafka%E6%BA%90%E7%A0%81%E7%BC%96%E8%AF%91%E5%AE%89%E8%A3%85.assets/image-20210806215234596.png)]

./zkServer.sh start #启动命令 ./zkServer.sh status # 查看运行状态

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-3adbsrY3-1629162748607)(kafka%E6%BA%90%E7%A0%81%E7%BC%96%E8%AF%91%E5%AE%89%E8%A3%85.assets/image-20210811193047096.png)]


启动完成显示如上

查看各节点状态

192.168.xxx.xxx

在这里插入图片描述

192.168.xxx.xxx

在这里插入图片描述

192.168.xxx.xxx

在这里插入图片描述

kafka配置安装

官网地址下载()

在这里插入图片描述

上载文件到服务器指定目录

cd /usr/local/src/tool/ 解压文件 tar -zxvf kafka_2.13-2.8.0.tgz -C /usr/local/ mv kafka_2.13-2.8.0/ kafka cd kafka/ mkdir kafka-logs //保存日志文件目录 非必须创建

解压后文件目录

cd /usr/local/kafka

在这里插入图片描述

修改配置文件 cd /usr/local/kafka/config

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zwdpxx.html