参考自kafka listeners 和 advertised.listeners配置内外网都可用
背景
在服务器9092端口上启动kafka后,发现本地环境连接不上,判断是9092端口没有对外暴露,localhost能访问,外网无法访问
以服务器公网IP10.184.24.49为例
方案
修改kafka配置,一开始增加了如下行:
advertised.listeners=PLAINTEXT://10.184.24.49:9092
修改后kakfa直接无法启动了,找不到broker
换成如下配置后启动成功,且本地环境可以连接上
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
本地连接测试:
kafka-console-consumer --bootstrap-server 10.184.24.49:9093 --topic rt-data-stream
网友评论