Kafka：如何重新使用未提交/未确认的消息

Question

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

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

Answer 1

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