golang使用kafka报错c.client.config.C

2021-02-23  本文已影响0人  时彬斌

在使用kafka时报错:
c.client.config.Config.Consumer.Offsets.CommitInterval undefined
排查后发现当前的github.com/Shopify/sarama 版本是v1.26.0 的版本;
将sarama的版本从go.mod里删除,并重新下载,实际上就是把版本升级到v1.28.0;
再次启动时编译通过。
参考资料:https://github.com/bsm/sarama-cluster/issues/307

上一篇 下一篇

猜你喜欢

热点阅读