java - 卡夫卡 : How to re-consume un committed/not Acknowledged message

Question

我们正在使用手动提交策略。我们配置了一个 bean 来提交所有成功消费的消息。我们正在尝试添加一个逻辑来重新使用未确认的消息。我们面临着相同的消息被消费但重新消费的时间间隔不统一的问题。有时很快就会被重新消耗，但有时需要几个小时。

如何确保未提交的消息在指定时间内被消耗。

Answer 1

您可以对 Consumer 执行 seek() 操作，将其重置为特定偏移量。