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

用到的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

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

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

navicat 连接 mysql 报错：client does not support authentication protocal requested by server
标题 navicat 连接 mysql 报错:client does not support authentication protocal requested by server 转载自:https ...
go连接Kafka报错kafka: client has run out of available brokers to talk to
问题出现的场景: 有个go写的项目,原来是用go vendor来管理依赖包的,现在改为是用go module方式了,转换之后,编译成功,发现了上面的错误.很显然连接kafka集群报错了. 问题的原因: ...
c3p0连接池报错 A client timed out while waiting
今天在看c3p0连接池的时候,因为连接数据库疯狂报错 com.mchange.v2.resourcepool.TimeoutException: A client timed out while wa ...
nodejs连接mysql报错：Client does not support authentication protocol requested by server; consider upgrad
由于本人是前端,mysql只是偶尔做一下小项目会用到,大概一年没有用了. 今天用mac通过brew下载了一个8.0.12版本的mysql;然后用egg进行连接,egg是阿里封装的一个nodejs框架. ...
golang连接mysql报错：this authentication plugin is not supported 解决方案
MySQL升级8.0以上版本后,在用第三方库github.com/Go-SQL-Driver/MySQL打开数据库时会报错this authentication plugin is not suppo ...
flink连接kafka报错
问题描述: 通过本地idea方式连接kafka,报如下错误: 可能原因:本地程序会查询本地配置,看是否存在ip映射,可能是本地ip映射不存在,导致连接kafka失败.(主要是由于kafka的serve ...
【kafka】连接kafka报错 partitions have leader brokers without a matching listener
1.概述一个正常的kafka消费者,开始正常,后来报错 partitions have leader brokers without a matching listener WARN [tag-se ...
R语言连接MySQL报错：could not run statement: The used command is not allowed with this MySQL version
版本说明 R版本:3.5 MySQL版本:8.0 RMySQL版本:0.10.19 情景说明: 使用RMySQL成功连接到MySQL数据库,可以进行查询操作,但在插入时报错,提示信息如下: con & ...
连接kafka报错:1 partitions have leader brokers without a matching listener
服务输出部分错误日志截图 2020/12/25 下午2:32:442020-12-25 14:32:44.320 WARN [tag-service,,,] 1 --- [ntainer#4-0-C- ...

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

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

最新文章

热门文章