在使用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
在使用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
本文标题:golang使用kafka报错c.client.config.C
本文链接:https://www.haomeiwen.com/subject/fnedfltx.html
网友评论