关于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-23增量更新怎么做?-icode9专业技术文章分享
- 2024-11-23压缩包加密方案有哪些?-icode9专业技术文章分享
- 2024-11-23用shell怎么写一个开机时自动同步远程仓库的代码?-icode9专业技术文章分享
- 2024-11-23webman可以同步自己的仓库吗?-icode9专业技术文章分享
- 2024-11-23在 Webman 中怎么判断是否有某命令进程正在运行?-icode9专业技术文章分享
- 2024-11-23如何重置new Swiper?-icode9专业技术文章分享
- 2024-11-23oss直传有什么好处?-icode9专业技术文章分享
- 2024-11-23如何将oss直传封装成一个组件在其他页面调用时都可以使用?-icode9专业技术文章分享
- 2024-11-23怎么使用laravel 11在代码里获取路由列表?-icode9专业技术文章分享
- 2024-11-22怎么实现ansible playbook 备份代码中命名包含时间戳功能?-icode9专业技术文章分享