我们正在使用手动提交策略。我们配置了一个 bean 来提交所有成功消费的消息。我们正在尝试添加一个逻辑来重新使用未确认的消息。我们面临着相同的消息被消费但重新消费的时间间隔不统一的问题。有时很快就会被重新消耗,但有时需要几个小时。
如何确保未提交的消息在指定时间内被消耗。
最佳答案
您可以对 Consumer
执行 seek()
操作,将其重置为特定偏移量。
关于java - 卡夫卡 : How to re-consume un committed/not Acknowledged message,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54749515/