使用DeadLetterPublishingRecoverer和手动确认模式的Spring Kafka侦听器

Question

我很难理解如何解决这个问题，所以我在这里问这个问题，希望其他人已经面临同样的问题。我们正在以手动确认模式运行@KafkaListener，死信恢复程序的重试限制为3。由于业务逻辑，在特定情况下（外部依赖），我们不确认消息并暂停消费5分钟，因此需要手动确认模式。

此外，我们确实需要由于某种原因无法处理的消息的死信队列。

现在，在手动确认模式下的问题是，当侦听器/消费者达到重试限制并将其移动到dl队列时，他不会确认消息。

如果消费者服务将重新启动，他会尝试一次又一次地使用消息，并将它们移动到dl队列。

有没有办法解决这个问题？

来自汉堡的感谢和问候！

Answer 1

在提供给ContainerListenerFactory的SeekToCurInterrorHandler实例上，可以将commitRecovered设置为true。

请在这里留档

public void setCommitRecovered（布尔commitRecovered）

设置为true以提交已恢复记录的偏移量。容器必须是

Answer 2

如果可能的话，我会尽量避免使用手动确认；也许通过增加max.poll。间隔而是ms。

如果您使用AckMode。MANUAL_IMMEDIATE，直接在错误处理程序中的消费者上执行提交是安全的。

子类的SeekToMONtErrorHandler和覆盖句柄（），如果super.handle（）没有抛出异常，这意味着重试被超过，你可以提交消费者上的偏移量。