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

千鹤·重弹 发表于: 2018-06-25   最后更新时间: 2018-06-26 09:29:27   3,539 游览

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

kafka
发表于 2018-06-25
千鹤·重弹
添加评论

消息应该是被跳过了。如果后面有成功的，如果你提交了offset，那就跳过了

回复
回答于 6年前
半兽人

假如我不想跳过呢？本地的SubscriptionState里维持的offset有办法rollback么？

0 0 回复

没办法的， kafka只有 按下标顺序读取的。

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。