当前位置:   article > 正文

zookeeper3.7.0 + kafka2.8.0 集群搭建干货_kafka3.7.0 zookeeper

kafka3.7.0 zookeeper

一、资源下载

zookeeper 3.7  下载地址:https://mirrors.bfsu.edu.cn/apache/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz

kafka 2.8 下载地址:https://mirrors.bfsu.edu.cn/apache/kafka/2.8.0/kafka_2.12-2.8.0.tgz

二、环境准备

准备3台centos8 虚拟机,并按一下操作进行配置

机器hostnameip
第1台node0192.164.4.123
第2台node1192.164.4.124
第3台node2192.164.4.125

三、修改/etc/hostname 和/etc/hosts

  1. # 第1台操作如下
  2. # 修改 hostname
  3. echo "node0" > /etc/hostname
  4. # 修改 hosts
  5. echo "192.164.4.123 node0" >> /etc/hosts
  6. echo "192.164.4.124 node1" >> /etc/hosts
  7. echo "192.164.4.125 node2" >> /etc/hosts
  8. # 关闭防火墙
  9. systemctl stop firewalld.service
  10. systemctl disable firewalld.service
  11. # 重启网络配置
  12. systemctl restart NetworkManager.service
  13. # 验证
  14. hostname
  15. ping node0
  1. # 第2台操作如下
  2. # 修改 hostname
  3. echo "node1" > /etc/hostname
  4. # 修改 hosts
  5. echo "192.164.4.123 node0" >> /etc/hosts
  6. echo "192.164.4.124 node1" >> /etc/hosts
  7. echo "192.164.4.125 node2" >> /etc/hosts
  8. # 关闭防火墙
  9. systemctl stop firewalld.service
  10. systemctl disable firewalld.service
  11. # 重启网络配置
  12. systemctl restart NetworkManager.service
  13. # 验证
  14. hostname
  15. ping node1
  1. # 第3台操作如下
  2. # 修改 hostname
  3. echo "node2" > /etc/hostname
  4. # 修改 hosts
  5. echo "192.164.4.123 node0" >> /etc/hosts
  6. echo "192.164.4.124 node1" >> /etc/hosts
  7. echo "192.164.4.125 node2" >> /etc/hosts
  8. # 关闭防火墙
  9. systemctl stop firewalld.service
  10. systemctl disable firewalld.service
  11. # 重启网络配置
  12. systemctl restart NetworkManager.service
  13. # 验证
  14. hostname
  15. ping node2

四、zookeeper 集群配置

下载zookeeper 并解压到 /obedu/zookeeper ,按以下操作配置完成配置

  1. # 在第1台机器的 /obedu/zookeeper/config 目录创建 zoo.cfg 文件, 加入以下内容
  2. # ---------------------------------------------------
  3. clientPort=2181
  4. clientPortAddress=0.0.0.0
  5. maxClientCnxns=0
  6. dataDir=/obaedu/zookeeper/data
  7. dataLogDir=/obaedu/zookeeper/logs
  8. tickTime=20000
  9. initLimit=100
  10. syncLimit=50
  11. quorumListenOnAllIPs=true
  12. leaderServes=yes
  13. server.0=node0:2888:3888
  14. server.1=node1:2888:3888
  15. server.2=node2:2888:3888
  16. # ---------------------------------------------------
  17. # myid 配置
  18. mkdir -p /obedu/zookeeper/data
  19. echo "0" > /obedu/zookeeper/data/myid
  20. # 启动
  21. /obedu/zookeeper/bin/zkServer.sh restart
  22. # 查看是否成功
  23. /obedu/zookeeper/bin/zkServer.sh status
  1. # 在第2台机器的 /obedu/zookeeper/config 目录创建 zoo.cfg 文件, 加入以下内容
  2. # ---------------------------------------------------
  3. clientPort=2181
  4. clientPortAddress=0.0.0.0
  5. maxClientCnxns=0
  6. dataDir=/obaedu/zookeeper/data
  7. dataLogDir=/obaedu/zookeeper/logs
  8. tickTime=20000
  9. initLimit=100
  10. syncLimit=50
  11. quorumListenOnAllIPs=true
  12. leaderServes=yes
  13. server.0=node0:2888:3888
  14. server.1=node1:2888:3888
  15. server.2=node2:2888:3888
  16. # ---------------------------------------------------
  17. # myid 配置
  18. mkdir -p /obedu/zookeeper/data
  19. echo "1" > /obedu/zookeeper/data/myid
  20. # 启动
  21. /obedu/zookeeper/bin/zkServer.sh restart
  22. # 查看是否成功
  23. /obedu/zookeeper/bin/zkServer.sh status
  1. # 在第3台机器的 /obedu/zookeeper/config 目录创建 zoo.cfg 文件, 加入以下内容
  2. # ---------------------------------------------------
  3. clientPort=2181
  4. clientPortAddress=0.0.0.0
  5. maxClientCnxns=0
  6. dataDir=/obaedu/zookeeper/data
  7. dataLogDir=/obaedu/zookeeper/logs
  8. tickTime=20000
  9. initLimit=100
  10. syncLimit=50
  11. quorumListenOnAllIPs=true
  12. leaderServes=yes
  13. server.0=node0:2888:3888
  14. server.1=node1:2888:3888
  15. server.2=node2:2888:3888
  16. # ---------------------------------------------------
  17. # myid 配置
  18. mkdir -p /obedu/zookeeper/data
  19. echo "2" > /obedu/zookeeper/data/myid
  20. # 启动
  21. /obedu/zookeeper/bin/zkServer.sh restart
  22. # 查看是否成功
  23. /obedu/zookeeper/bin/zkServer.sh status

五、kafka集群配置

 kafka 集群配置的前提先完成 zookeeper 集群配置。

下载kafka 并解压到 /obedu/kafka ,按以下操作配置完成配置

  1. # 第1台机器 vim /obedu/kafka/config/server.properties, 按以下内容修改
  2. # ---------------------------------------------------------
  3. broker.id=0
  4. delete.topic.enable=true
  5. auto.create.topics.enable=true
  6. listeners=PLAINTEXT://192.168.4.123:9092
  7. advertised.host.name=192.168.4.123
  8. advertised.listeners=PLAINTEXT://192.168.4.123:9092
  9. zookeeper.connect=node0:2181,node1:2181,node2:2181
  10. zookeeper.connection.timeout.ms=6000
  11. log.dirs=/obaedu/kafka/logs
  12. # ---------------------------------------------------------
  13. # 启动 kafka
  14. /obaedu/kafka/bin/kafka-server-start.sh -daemon /obaedu/kafka/config/server.properties
  1. # 第2台机器 vim /obedu/kafka/config/server.properties, 按以下内容修改
  2. # ---------------------------------------------------------
  3. broker.id=1
  4. delete.topic.enable=true
  5. auto.create.topics.enable=true
  6. listeners=PLAINTEXT://192.168.4.124:9092
  7. advertised.host.name=192.168.4.124
  8. advertised.listeners=PLAINTEXT://192.168.4.124:9092
  9. zookeeper.connect=node0:2181,node1:2181,node2:2181
  10. zookeeper.connection.timeout.ms=6000
  11. log.dirs=/obaedu/kafka/logs
  12. # ---------------------------------------------------------
  13. # 启动 kafka
  14. /obaedu/kafka/bin/kafka-server-start.sh -daemon /obaedu/kafka/config/server.properties
  1. # 第3台机器 vim /obedu/kafka/config/server.properties, 按以下内容修改
  2. # ---------------------------------------------------------
  3. broker.id=2
  4. delete.topic.enable=true
  5. auto.create.topics.enable=true
  6. listeners=PLAINTEXT://192.168.4.125:9092
  7. advertised.host.name=192.168.4.125
  8. advertised.listeners=PLAINTEXT://192.168.4.125:9092
  9. zookeeper.connect=node0:2181,node1:2181,node2:2181
  10. zookeeper.connection.timeout.ms=6000
  11. log.dirs=/obaedu/kafka/logs
  12. # ---------------------------------------------------------
  13. # 启动 kafka
  14. /obaedu/kafka/bin/kafka-server-start.sh -daemon /obaedu/kafka/config/server.properties

到这里就完成了zookeeper+kafka集群搭建,如有问题可留言一起讨论!!!

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小丑西瓜9/article/detail/444777
推荐阅读
相关标签
  

闽ICP备14008679号