最近做了一个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)

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

您的访问IP 3.134.81.206‧最早于 2024年4月29日 7时29分45秒 阅读过本文 ‧ 为本文提供了 1 热度 1 阅读量