go项目连接kafka报错问题out of available brokers to talk

雨中笑 goland 2373热度

简介kafka: client has run out of available brokers to talk to (Is your cluster reachable?)

最近做了一个go项目需要使用到kafka,我在本地上跑都是没问题,本地环境连接的是docker部署的kafka,在上预发的时候出现看日志了

 kafka: client has run out of available brokers to talk to (Is your cluster reachable?)

发现这个错误第一反应是防火墙、连接不通等,

查看到都是访问得到,后面就排查应该是 kafka的版本问题了,因为我本地的版本比较新是 kafka_2.13-3.1.0,预发上使用的版本是 kafka_2.11-0.10.2.2

而我使用了github.com/Shopify/sarama,这个包版本是v1.32.0。

了解到smrama v1.20之后的版本加入了zstd压缩算法,需要用到cgo。

然后在go.mod文件下添加

replace github.com/Shopify/sarama => github.com/Shopify/sarama v1.19.0

执行 go mod tidy

提交代码就解决了问题了


很赞哦!(8)

本文阅读量 4843发布于 2022年4月26日

您的访问IP 3.229.117.191最早于 2024年5月26日 22时10分28秒 阅读过本文 为本文提供了 1 热度 1 阅读量

文章评论
回帖