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
在config/server.properteis中,添加
listeners=
默认是localhost,只能本机访问,换成你的内网ip即可。
我在
/etc/host
配置了地址映射10.23.1.188 kafka1
,然后我在配置文件里配置的是listeners:kafka1:9092
,我代码里的配置是bootstrap-servers: kafka1:9092
,我也在hosts文件里配置了映射,我现在是代码在外网启动能够正常消费,在内网运行消费就报错。你得把报什么错贴出来呀...
你的答案