用到的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,重新启动就导致这样的问题。
解决思路:

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

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支持哪些版本也是个值得一看的问题。