如何配置 Kafka 重复未提交的偏移量消息？

Question

假设我的主题有这些消息：

[A, A, B, A, B]

我的应用程序成功处理了 A，但 B 抛出了意外异常。我认为更改 不会提交偏移量，因此侦听器将 重复处理相同的消息，直到 Kafka 侦听器无一例外地处理消息 。我已将 enable.auto.commit 和 ackOnError 设置为 false，但侦听器仍在跳转到下一条消息，无论消息是 A 还是 B。

我怎样才能完成这个期望的行为，让我的侦听器尝试处理相同的消息，直到它无一例外地成功？

Answer 1

您需要配置 SeekToCurrentErrorHandler 以重播失败。

见the documentation。