參考自kafka listeners 和 advertised.listeners配置內(nèi)外網(wǎng)都可用
背景
在服務(wù)器9092端口上啟動(dòng)kafka后,發(fā)現(xiàn)本地環(huán)境連接不上,判斷是9092端口沒(méi)有對(duì)外暴露溉跃,localhost能訪問(wèn)撇吞,外網(wǎng)無(wú)法訪問(wèn)
以服務(wù)器公網(wǎng)IP10.184.24.49為例
方案
修改kafka配置详炬,一開(kāi)始增加了如下行:
advertised.listeners=PLAINTEXT://10.184.24.49:9092
修改后kakfa直接無(wú)法啟動(dòng)了裙品,找不到broker
換成如下配置后啟動(dòng)成功忍宋,且本地環(huán)境可以連接上
listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
listeners=INTERNAL://127.0.0.1:9092,EXTERNAL://10.184.24.49:9093
advertised.listeners=INTERNAL://127.0.0.1:9092,EXTERNAL://10.184.24.49:9093
inter.broker.listener.name=INTERNAL
本地連接測(cè)試:
kafka-console-consumer --bootstrap-server 10.184.24.49:9093 --topic rt-data-stream