关于Kafka些测试消费类后,消费Kafka集群Brocker上得数据报错解决Marking the coordinator storage12.babel:7667 (id: 2147483645
2021/5/24 18:31:31
本文主要是介绍关于Kafka些测试消费类后,消费Kafka集群Brocker上得数据报错解决Marking the coordinator storage12.babel:7667 (id: 2147483645,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
在搭建完成Kafka消费系统后,启动消费程序取消费平台得数据,出现如下得错误:
报错信息:
2021/05/24 16:55:17 118 INFO authenticator.AbstractLogin:59 - Successfully logged in. 2021/05/24 16:55:17 150 INFO utils.AppInfoParser:83 - Kafka version : 0.10.2.0 2021/05/24 16:55:17 150 INFO utils.AppInfoParser:84 - Kafka commitId : 576d93a8dc0cf421 2021/05/24 16:55:18 252 INFO internals.AbstractCoordinator:573 - Discovered coordinator storage12.babel:7667 (id: 2147483645 rack: null) for group aa-group-02. 2021/05/24 16:55:18 253 INFO internals.AbstractCoordinator:618 - Marking the coordinator storage12.babel:7667 (id: 2147483645 rack: null) dead for group aa-group-02
反复检查消费程序得配置信息,最后发现,接收平台数据得三塔集群机器均没有配置对应得生产者集群得平台信息,即未在集群平台本地得hosts文件中添加对应得生产者平台的IP对应信息导致。
找平台组做更改,然后再消费数据,解决当前的出错信息。
更改的命令如下:
//查看本地的集群主机hosts文件配置信息 more /etc/hosts //通过命令修改添加对应的生产者平台的hosts信息[改配置修改必须是在管理员账户下才能修改,其他用户修改无效] vim /etc/hosts //通过按”i“键输入对应的生产者平台的hosts信息
192.xxx.xx.11 storage11.babel storage11
192.xxx.xx.12 storage12.babel storage12
192.xxx.xx.13 storage13.babel storage13 完成后按”Esc“,手动输入”:wq!“即可保存对应的信息
至此解决对应的相关信息
对于其他报错,可能是对应的生产者和消费者的版本不对应,以及在做消费处理时,发现消费的数据处理会消耗大量时间,导致最后的连接的失败。
参考的文章如下:
https://www.freesion.com/article/1169969839/
可根据对应的操作变更自己消费组中的配置属性信息。
这篇关于关于Kafka些测试消费类后,消费Kafka集群Brocker上得数据报错解决Marking the coordinator storage12.babel:7667 (id: 2147483645的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-11-01UniApp 中组件的生命周期是多少-icode9专业技术文章分享
- 2024-11-01如何使用Svg Sprite Icon简化网页图标管理
- 2024-10-31Excel数据导出课程:新手从入门到精通的实用教程
- 2024-10-31Excel数据导入课程:新手入门指南
- 2024-10-31RBAC的权限课程:新手入门教程
- 2024-10-31Svg Sprite Icon课程:新手入门必备指南
- 2024-10-31怎么配置 L2TP 允许多用户连接-icode9专业技术文章分享
- 2024-10-31怎么在FreeBSD上 安装 OpenResty-icode9专业技术文章分享
- 2024-10-31运行 modprobe l2tp_ppp 时收到“module not found”消息提醒是什么-icode9专业技术文章分享
- 2024-10-31FreeBSD的下载命令有哪些-icode9专业技术文章分享