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

千鹤·重弹 发表于: 2018-06-25   最后更新时间: 2018-06-26  
  •   0 订阅,87 游览

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







发表于: 24天前   最后更新时间: 23天前   游览量:87
上一条: 到头了!
下一条: 已经是最后了!

评论…


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