kafka内外网配置问题?

人生如梦 发表于: 2020-01-08   最后更新时间: 2020-01-08  

kafka2.12-2.1.0,我在内网部署了单击版kafka,想内外网都能访问,我通过大佬半兽人的文章,我在自己电脑连接成功实现了内外网都能访问,我测试的环境是我的电脑内外网都能用,我将消费端代码部署到另外一台内外服务器上时,启动就报错了。

org.springframework.context.ApplicationContextException: Failed to start bean 'o
rg.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata


您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: kafka同一个消费组的多实例,有一些实例只消费消息,处理完数据后不发出消息到其他Topic。
下一条: 重启服务器后监听不到kafka9092端口号

  • 在config/server.properteis中,添加

    listeners=
    

    默认是localhost,只能本机访问,换成你的内网ip即可。

    • 我在etc/host配置了地址映射10.23.1.188 kafka1,然后我在配置文件里配置的是listeners:kafka1:9092,我代码里的配置是bootstrap-servers: kafka1:9092,我也在hosts文件里配置了映射,我现在是代码在外网启动能够正常消费,在内网运行消费就报错