Spring kafka 2.7.8 的 setAckOnError() 方法

Question

将我们的 spring kafka 升级到 2.7.8 时，我们在 setAckOnError(false) 方法中遇到错误，因为它现在已被弃用。现在有什么办法可以将错误的确认设置为 false 吗？还有其他方法可以帮助我将错误确认设置为 false 吗？ P.S：我是 Kafka 的新手，感谢任何帮助！

Answer 1

属性 被发现有一个（非常小的）时间漏洞，记录可能在错误处理程序处理它之前被确认；如果应用程序当时死机，记录可能会“丢失”。

它已被错误处理程序中的新功能所取代 ackAfterHandle；默认情况下为真 - 即记录的偏移量仅在错误处理程序“处理”错误时才提交。

如果错误处理程序（例如 SeekToCurrentErrorHandler）抛出异常（在重新定位分区之后），则记录现在永远不会被确认。

不再需要额外配置。

有关详细信息，请参阅 。