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 

问题完美解决了

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐