1. 程式人生 > >kafka消費者報錯:Failed to add leader for partitions

kafka消費者報錯:Failed to add leader for partitions

      最近遇到過這種錯誤兩次了,通過describe來看的時候是正常的,但是總會報錯,猜測試網路問題。果不其然,

一次是一臺kafka的機器的防火牆沒有關掉,關掉之後就ok了。

另外一次是因為工程把主機配置localhost後面了。這樣的話,導致kafka總是去127.0.0.1通訊,導致報錯。去掉hosts檔案中127.0.0.1後面的主機名配置就可以了。

比如

127.0.0.1 localhost kafka

去掉kafka的配置就可以了