我很高兴地宣布 Apache Kafka 版 Spring 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 属性

• 新的 ErrorhandlingDeserializer 可以捕获反序列化异常，然后将其路由到 ErrorHandler

• 内嵌 Kafka 代理现在可以与 JUnit 5 测试一起使用

有关更多信息，请参阅文档中的“新增功能”章节和更改日志。

此外，Apache Kafka 版 Spring 集成 (spring-integration-kafka) 3.1.0.RELEASE 也已发布；它基于 Apache Kafka 版 Spring 2.2 和 Spring 集成 5.1。

项目页面 | GitHub | 问题 | 文档 | Stack Overflow | Gitter