返回到文章

采纳

编辑于

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

kafka

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