kafka enable.auto.commit=false,模拟fetch回数据消费侧业务处理失败的场景(这样不会触发手动提交),发现下次fetchRequest里带的offset已经是消费成功offset了,怎么破?

现在的现象就是lag值一直不为0,服务侧显示有一条数据未消费






发表于: 4月前   最后更新时间: 4月前   游览量:365
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 消息应该是被跳过了。如果后面有成功的,如果你提交了offset,那就跳过了
  • 评论…
    • in this conversation