在搭建完成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/
可根據對應的操作變更自己消費組中的配置屬性信息。
