写文章
- @lwysgmx
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
kafka客户端sarama使用之手动提交offset
项目需求不能丢失任何一条消息，网上手动提交offset的代码好像有点小问题，在这里改一下package mainimport ("context""fmt"sarama "github.com/Shopify/sarama")type consumerGroupHandler struct {name string}func (consumerGroupHandler) Setup(_ saram
暂无文章信息