我很高兴地宣布 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 嵌入式 broker 用于测试）。

亮点

• SeekToCurrentErrorHandler 现在可以“跳过”重复失败的记录

• 此类“跳过”的记录可以发布到死信主题（或由应用程序代码以其他方式处理）

  • 标头添加了有关失败的诊断信息

• 使用事务时，可以使用默认的 AfterRollbackProcessor 实现相同的功能

• 现在可以使用监听器容器工厂来创建任何任意的监听器容器，而不仅仅是 @KafkaListener 的容器

  • 这允许更方便地使用 Spring Boot 的自动配置属性用于任何容器

• @KafkaListener 注解现在可以覆盖容器工厂的 concurrency 和 autoStartup 属性

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

• 嵌入式 kafka broker 现在可以与 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