当前位置: 首页 > news >正文

基于kafka的分布式日志收集平台项目(续)

#第一个容易错的地方

上次做到测试集群的创建topic时出现了错误

具体错误是配置信息出错了,然后报错如下:

#现在来具体警戒哪些地方要特别注意:

###   node.id 和listeners 和advertised.listeners这三行是每一台机器(每个节点)都不一样的,名字根据自己的机器的名字来,kafka1的就是kafka1,kafka2的就是kafka2,然后controller.quorum.voters这一行都一样,像上图如此

#第二个容易错的地方

像如图这样,应该把192.168.20.2改为192.168.126.2   要让网关和IP网段匹配

#第三个容易错的地方

然后输入bin/kafka-topics.sh --create --bootstrap-server kafka3:9092 --replication-factor 3 --partitions 3 --topic my_topic

出现 [2025-03-25 18:37:15,806] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (kafka3/192.168.126.176:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

那就检查kafka3的服务状态

# 确认服务是否运行
ps aux | grep kafka

# 检查端口监听
ss -tuln | grep 9092  或ps aux|grep 9092

如果没反应则说明端口关闭,一般是以下地方出了问题,上面也提到过这里要认真配置

#在完成上面纠错之后,再进行以下步(下面步骤之前执行过,没错,在执行一遍,记住uuid要换成自己的uuid,然后什么时候开一台机执行命令,什么时候同时开启三台机器一起命令要注意):

要先进入如图目录将里面内容先删干净:

即这一步:

# 在其中一台执行,生成集群UUID命令,拿到集群UUID保存在当前tmp_random文件中
bin/kafka-storage.sh random-uuid >tmp_random
# 查看uuid
 [root@chainmaker1 kafka_2.13-3.6.1]# cat tmp_random
z3oq9M4IQguOBm2rt1ovmQ

# 在所有机器上执行,它会初始化存储区域,为 Kafka 集群的元数据存储和后续操作做好准备。z3oq9M4IQguOBm2rt1ovmQ为自己生成的集群uuid

bin/kafka-storage.sh format -t z3oq9M4IQguOBm2rt1ovmQ -c /opt/kafka_2.13-3.6.1/config/kraft/server.properties

#重新加载systemd配置
  systemctl daemon-reload
  
  #启动kafka服务
  systemctl  start  kafka
  

# 创建topic 
bin/kafka-topics.sh --create --bootstrap-server kafka3:9092 --replication-factor 3 --partitions 3 --topic my_topic

** --replication-factor指定副本因子,--partitions指定分区数,--topic指定主题名称。

# 查看topic
 bin/kafka-topics.sh --list --bootstrap-server kafka3:9092

然后就大功告成!

http://www.dtcms.com/a/98426.html

相关文章:

  • AnimateCC基础教学:随机抽取获奖名单及奖品-V1.0原型版
  • 双非一本毕业测试工作一年想转C++开发,嵌入式Linux与音视频方向哪个方向更合适?
  • JavaScript使用
  • 浅拷贝或深拷贝js数组或对象的方法
  • 常用数据库
  • 使用 Docker Compose 在单节点部署多容器
  • C++ 变量与初始化详解(十五)
  • 【商城实战(100)】商城败局启示录:探寻成功的反方向
  • 【ChatBox】deepseek本地部署
  • 解决 Gradle 构建错误:Could not get unknown property ‘withoutJclOverSlf4J’
  • 【Linux笔记】进程间通信——匿名管道||进程池
  • Linux 系统部署Jump Server服务
  • 使用msmtp和mutt在CentOS上发送指定目录下的所有文件作为邮件附件
  • 聚焦高德开放平台的地图应用场景:创新实践与技术解析
  • 若依赖前端处理后端返回的错误状态码
  • 【新手初学】SQL注入getshell
  • 1、C51单片机(STC8G2K64S4)串口实验
  • Java开发者指南:深入解析PBFT拜占庭容错算法
  • pycharm终端操作远程服务器
  • 【磁盘扩容】linux磁盘扩容
  • Koordinator-Metric查询
  • Python3基础库入门(个人学习用)
  • [ C语言 ] | 从0到1?
  • Redis设计与实现-哨兵
  • 分销商城小程序开发六大核心功能详解
  • 用react实现router路由
  • C++ 中名字的作用域、概念、嵌套与实践(十八)
  • Java基础-22-基本语法-实体类
  • 【MySQL篇】事务管理,事务的特性及深入理解隔离级别
  • Unity功能模块一对话系统(5)-完善对话流程及功能