在将我们的spring-kafka升级到2.7.8时,我们在setAckOnError(false(方法中遇到了错误,因为它现在已经被弃用了。现在有没有办法将错误的确认设置为false?有其他方法可以帮助我将其设置为错误确认为false吗?附言:我是卡夫卡的新手,任何帮助都很感激!
该属性被发现有一个(非常小的(定时漏洞,在错误处理程序处理之前,记录可能会被确认;如果应用程序在那个时候失效,记录可能是";丢失";。
它被错误处理程序ackAfterHandle
中的一个新特性所取代;这在默认情况下是真的,即记录的偏移量只有在错误处理程序";手柄";错误。
如果错误处理程序(如SeekToCurrentErrorHandler
(抛出异常(在重新定位分区之后(,则记录现在永远不会被确认。
不再需要额外的配置。
有关更多详细信息,请参阅Spring Kafka AckOnError。