在使用java客戶端連接kafka時,怎么都連接不上,防火墻端口也開放了,后面查資料得知需要將修改kafka安裝目錄下的config/server.properties文件:
# 允許外部端口連接
listeners=PLAINTEXT://192.168.38.22:9092
但是這樣在執(zhí)行kafka生產(chǎn)者命令時又出現(xiàn)問題:Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.文章來源:http://www.zghlxwxcb.cn/news/detail-514507.html
kafka啟動后會在zookeeper的/brokers/ids下注冊監(jiān)聽協(xié)議,包括IP和端口號,客戶端連接的時候,會取得這個IP和端口號。原理是因為listeners和advertised.listeners的區(qū)別,advertised.listeners才是真正暴露給外部使用的連接地址,會寫入到zookeeper節(jié)點中的。于是再次進(jìn)行修改,把IP配置到advertised.listeners中:文章來源地址http://www.zghlxwxcb.cn/news/detail-514507.html
# 允許外部端口連接
listeners=PLAINTEXT://192.168.38.22:9092
# 外部代理地址
advertised.listeners=PLAINTEXT://192.168.38.22:9092
到了這里,關(guān)于報錯:Connection to node -1 (localhost/127.0.0.1:9092) could not be established.的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!