在使用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
有疑问加站长微信联系(非本文作者)