kafka發布消息報錯LEADER_NOT_AVAILABLE

我的kafka是CDH上的2.11版本

在linux客戶端啟動了kafka自帶的producer 和consumer后能正常生產和消費

但是，

在idea啟動了自定義的生產者向kafka發送數據的時候報：

WARN Error while fetching metadata with correlation id 0 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

並且開啟消費者后看不到數據，說明生產者發送數據失敗

有人說：

修改server.properties，然后將每個節點的kafka重啟即可解決

即：

 

 分別修改為：

 

listeners=PLAINTEXT://slave01:9092

advertised.listeners=PLAINTEXT://slave01:9092

但是：對我不解決問題

后來，新加了一個broker,原來是兩個broker, 所以可能根據zookeeper的選舉機制，找不到leader. 如果是奇數個的時候就很容易選舉出來leader了。所以很簡單，增加一個kafka的實例即可。