2017-09-25 24 views
0

異常打造主題爲「主」無法在線程使用卡夫卡AdminUtils.createTopic

kafka.common.KafkaException: Failed to parse the broker info from zookeeper: 

{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://localhost:9093"],"jmx_port":-1,"host":"localhost","timestamp":"1506322454462","port":9093,"version":4} 

,這是什麼可能的解決方案?

我已經檢查到處,但似乎沒有工作。

回答

0

檢查代理和客戶端上的kafka版本,可能您使用的是過時的客戶端。

+0

每當我嘗試創建toipc時,在Zookeeper終端處得到「EndOfStreamException:無法從客戶端會話id 0x15eb7cf1d750009讀取其他數據,可能客戶端已關閉套接字」。並使用依賴關係「org.apache.kafka」%「kafka_2.11」%「0.10.0.1」用sbt構建 –