在使用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.Config.Consumer.Offsets.CommitInterval undefined问题
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
相关阅读更多精彩内容
- 事情起因是这样的。我们环境需要用到kafka,现在都是使用容器化的部署,大佬就找了个github星最多docker...
- 环境 使用背景 在使用ceph前使用heketi搭建的glusterfs cluster用于kubernetes ...
- 前言 在 Web 开发中,热重启在很多地方都会用到,它能极大提升开发效率,在我们修改完代码后保存,就能自动重启运行...