在搭建完成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/
可根据对应的操作变更自己消费组中的配置属性信息。