問題出現的場景：

有個go寫的項目，原來是用go vendor來管理依賴包的，現在改為是用go module方式了，轉換之后，編譯成功，發現了上面的錯誤。很顯然連接kafka集群報錯了。

問題的原因：

網上搜了下，很多說是防火墻啥的問題，其實不是。本質原因是，我項目使用的如下kafka客戶端庫

github.com/Shopify/sarama

版本升級到當前最新版，這個最新版無法連接kafka集群，換為原來的舊版本就沒有問題。

大家不要被報錯內容迷惑，跟客戶端多少沒有關系的。特此記錄一下，以作備忘。

?

?

總結

以上是生活随笔為你收集整理的go连接Kafka报错kafka: client has run out of available brokers to talk to的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。