Flink Job 任务从kafka topic中抓取数据时,出现问题(Timeout expired while fetching topic metadata)
错误:org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata在测试环境的时候一点事都没有,当部署到生产后出现了这个问题,找了很多网上的都是不行又说版本对不上不兼容的,有改变listeners=PLAINTEXT://当前服务器的ip:9092 这种的这两种都不行打开
·
错误:
org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata
在测试环境的时候一点事都没有,当部署到生产后出现了这个问题,找了很多网上的都是不行
又说版本对不上不兼容的,有改变listeners=PLAINTEXT://当前服务器的ip:9092 这种的
这两种都不行
打开spring 打开dubug 日志,发现 连接kafka 的地址变成了 kafka主机名加9092如:localhost:9092
这点俺就很好奇的为什么指定了他还去那服务器名去进行连接
没办法,指定一下吧
在服务器上编辑kafka 的server.properties 文件
找到advertised 没有的话添加一个就是了
advertised.listeners=PLAINTEXT://当前服务器的ip:9092
然后保存退出,重启kafka
advertised.listeners 限定了kafka数据广播的ip
更多推荐
已为社区贡献12条内容
所有评论(0)