1. 連接kafka時(shí)報(bào)錯(cuò)：Connection to xxx could not be established. Broker may not be available.

在配置文件config/server.properties中，確認(rèn)listeners和advertised.listeners的配置。

listeners=PLAINTEXT://kafka-host:9092 advertised.listeners=PLAINTEXT://kafka-host:9092

在訪問(wèn)kafka的機(jī)器上，應(yīng)在hosts文件中添加對(duì)應(yīng)主機(jī)名的映射。

windows系統(tǒng)的主機(jī)映射文件為：C:\Windows\System32\drivers\etc\hosts

Linux系統(tǒng)的主機(jī)映射文件為：/etc/hosts

192.168.0.181 kafka-host

2. 由于配置修改為主機(jī)名的形式導(dǎo)致metricbeat.exe監(jiān)控時(shí)出現(xiàn)錯(cuò)誤

采用ip地址連接時(shí)，錯(cuò)誤信息：

No advertised broker with address xx.xx.xx.xx:9092 found

修改為與配置一致的主機(jī)名方式，正常上傳監(jiān)控?cái)?shù)據(jù)。

hosts: ["192.168.0.181:9092"]

修改為：

hosts: ["kafka-host:9092"]

但是使用kafka控制臺(tái)客戶端是可以通過(guò)ip地址進(jìn)行連接的。

總結(jié)

以上是生活随笔為你收集整理的kafka常见问题（持续更新）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。