Spring for Apache Kafka 2.2 发布
我很高兴地宣布 Spring for Apache Kafka 2.2.0.RELEASE 现已可用。
虽然 2.1.x 版本与 2.0.0 的 kafka-clients
jar 兼容(自 2.1.9 起),但此版本需要 2.0.0(并提供用于测试的 2.0.0 嵌入式代理)。
重点
-
SeekToCurrentErrorHandler
现在可以“跳过”重复失败的记录 -
此类“跳过”的记录可以发布到死信主题(或以其他方式由应用程序代码处理)
-
添加了包含故障诊断信息的标头
-
-
使用事务时,可以使用默认的
AfterRollbackProcessor
实现相同的功能 -
您现在可以使用侦听器容器工厂创建任何任意侦听器容器,而不仅仅是
@KafkaListener
的容器-
这使得可以更方便地对任何容器使用 Spring Boot 的自动配置属性
-
-
…@KafkaListener
注解现在可以覆盖容器工厂的concurrency
和autoStartup
属性