本文主要是介绍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连接Kafka报错kafka: client has run out of available brokers to talk to的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!