Spring for Apache Kafka 2.9 发布候选版本可用
我很高兴地宣布,Spring for Apache Kafka 2.9.0 的发布候选版本现已在Spring Milestone 存储库中提供 (2.9.0-RC1)。
Spring Boot 依赖项管理不提供此版本,但只要您覆盖 Kafka 依赖项(如此附录中所述),就可以与 Boot 2.7(或 2.6)一起使用,尤其是在使用嵌入式 Kafka 代理时。
值得注意的更改
-
此版本使用 3.2.0 的
kafka-clients
版本 -
非阻塞重试引导现在更加健壮
-
新的错误处理程序模式
默认情况下,在发生错误后,DefaultErrorHandler
会对上次轮询中剩余的记录执行查找,并在下次轮询时从代理重新获取它们。在错误率高且 max.poll.records
较大的情况下,这可能会对网络造成不必要的压力。出于此原因,错误处理程序具有一个新属性 seekAfterError
,当设置为 false
时,它不会查找记录,而是将剩余的记录保留在内存中,并暂停使用者以进行下一次轮询(或者如果错误处理程序配置为使用 ContainerPausingBackOffHandler
,则进行多次轮询……