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属性。