關於Kafka些測試消費類后,消費Kafka集群Brocker上得數據報錯解決Marking the coordinator storage12.babel:7667 (id: 2147483645 rack: null) dead for group aa-group-02


在搭建完成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/

可根據對應的操作變更自己消費組中的配置屬性信息。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM