go连接Kafka报错kafka: client has run out of available brokers to talk to
问题出现的场景：有个go写的项目，原来是用go vendor来管理依赖包的，现在改为是用go module方式了，转换之后，编译成功，发现了上面的错误。很显然连接kafka集群报错了。问题的原因：网上搜了下，很多说是防火墙啥的问题，其实不是。本质原因是，我项目使用的如下kafka客户端库github.com/Shopify/sarama版本升级到当前最新版，这个最新版无法连接kafka集群，换为原
·
问题出现的场景：
有个go写的项目，原来是用go vendor来管理依赖包的，现在改为是用go module方式了，转换之后，编译成功，发现了上面的错误。很显然连接kafka集群报错了。
问题的原因：
网上搜了下，很多说是防火墙啥的问题，其实不是。本质原因是，我项目使用的如下kafka客户端库
github.com/Shopify/sarama
版本升级到当前最新版，这个最新版无法连接kafka集群，换为原来的旧版本就没有问题。
大家不要被报错内容迷惑，跟客户端多少没有关系的。特此记录一下，以作备忘。
为开发者提供学习成长、分享交流、生态实践、资源工具等服务，帮助开发者快速成长。
更多推荐
3
0- 0
已为社区贡献1条内容
所有评论(0)