要想實現在本地連接服務器的kafka,則必須在遠程kafka配置遠程連接
默認的?kafka?配置是無法遠程訪問的,解決該問題有幾個方案。
方案1
advertised.listeners=PLAINTEXT://IP:9092
注意必須是 ip,不能是 hostname
方案2
advertised.listeners=PLAINTEXT://node0:9092
node0 是 hostname,需在 /etc/hosts 中 添加一行
172.16.89.80 node0
然后 必須在 遠程機(要訪問 kafka 的機器 windows)上修改 hosts文件,
C:\Windows\System32\drivers\etc\hosts
在末尾加上?
IP1 節點1 IP2 節點2
節點名與服務器上的 hostname 相同。
測試異常記錄
WARN [Consumer clientId=consumer-1, groupId=console-consumer-4184] Connection to node -1 (/172.16.89.80:9092) could not be established. Broker may not be available . (org.apache.kafka.clients.NetworkClient)
kafka 配置 與 console 啟動的 ip 不一致,如 配置文件中?listeners=PLAINTEXT://172.16.89.80:9092,啟動 是? localhost
kafka.errors.NoBrokersAvailable: NoBrokersAvailable
listeners=PLAINTEXT://172.16.89.80:9092