setAckOnError() method for Spring kafka 2.7.8



在将我们的spring-kafka升级到2.7.8时,我们在setAckOnError(false(方法中遇到了错误,因为它现在已经被弃用了。现在有没有办法将错误的确认设置为false?有其他方法可以帮助我将其设置为错误确认为false吗?附言:我是卡夫卡的新手,任何帮助都很感激!

该属性被发现有一个(非常小的(定时漏洞,在错误处理程序处理之前,记录可能会被确认;如果应用程序在那个时候失效,记录可能是";丢失";。

它被错误处理程序ackAfterHandle中的一个新特性所取代;这在默认情况下是真的,即记录的偏移量只有在错误处理程序";手柄";错误。

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

不再需要额外的配置。

有关更多详细信息,请参阅Spring Kafka AckOnError。

最新更新