Golang连接kafka报错: Errorkafka: client has run out of available brokers to talk to

go连接kafka问题报错: panic: Error creating consumer group client: kafka: client has run out of available brokers to talk to: 3 errors occurred:

苏墩墩

5707人浏览 · 2022-10-31 09:38:14

苏墩墩 · 2022-10-31 09:38:14 发布

用到的go包: “github.com/Shopify/sarama”
详细的报错内容如下：

2022/10/28 15:39:25 Error creating consumer group client: kafka: client has run out of available brokers to talk to: 3 errors occurred:
        * EOF
        * EOF
        * EOF
panic: Error creating consumer group client: kafka: client has run out of available brokers to talk to: 3 errors occurred:
        * EOF
        * EOF
        * EOF

功能模块是我写好的，之前测试一切正常。只是重新部署了kafka，重新启动就导致这样的问题。
解决思路:

首先想到是不是kafka部署的问题
用python客户端测试后，发现创建topic，生产数据，消费数据都是没有问题的。
想到是不是sarama的问题
之前的功能都是没有问题，更改的只是将kafka从单点更改到集群。重新下载了部署包，重新进行了集群的构建。
版本的问题 √

sarama中有指定版本的参数代码:

flag.StringVar(&version, "version", "2.1.1", "Kafka cluster version")

然后去查看部署的kafka节点的版本Version
kafka版本
一个默认的是 2.1.1
我部署的版本是: 0.11.0.0
你能想到我是怎么样才接受了这个才是kafka的版本的吗？差别真的太大了。
然后我拿着这个参数 -version 0.11.0 尝试启动系统。
我得到如下的结果:

2022/10/28 15:39:02 Starting a new FreeProxy consumer
2022/10/28 15:39:02 Error parsing Kafka version: invalid version `0.11.0`
panic: Error parsing Kafka version: invalid version `0.11.0`

goroutine 1 [running]:
log.Panicf({0x7b0586?, 0x0?}, {0xc00058ff10?, 0x0?, 0xc0000201a0?})
        D:/gogo/src/log/log.go:395 +0x67
main.main()
        F:/github/syncFiles/goApi/apiDesign/freeproxy.go:221 +0x1d7
exit status 2

没有这个版本？为什么？
这个我没搞清楚，猜测是部署的kafka版本太老了，之前用的是2.4.1的版本，现在居然部署了这个版本。这个部署包当时是从网盘拿的，估计是四五年前的版本了。

根据经验，咱使用它推荐的版本:
这个你推荐是不?
果然这次再启动系统就没有任何问题了。
看来多年的运维经验让我意识到版本的重要性。
有同学知道这几个版本的差别，0.11.0.0和2.1.1有啥重大的差别和发生了什么故事。请同学们私信留言我，我有空也查查。
sarama支持哪些版本也是个值得一看的问题。