我很高兴地宣布，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 属性。

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

• 嵌入式 kafka 代理现在可以与 JUnit 5 测试一起使用。

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

此外，Spring Integration for Apache Kafka (spring-integration-kafka) 3.1.0.RELEASE 也已可用；它基于 Spring for Apache Kafka 2.2 和 Spring Integration 5.1。

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