Spring for Apache Kafka 3.2.0, 3.1.5 和 3.0.17 现已发布

发布 | Soby Chacko | 2024 年 5 月 21 日 | ...

代表团队和社区中所有贡献者，我们很高兴宣布 Spring for Apache Kafka 3.2.0 已正式发布。

Spring for Apache Kafka 3.2.0

3.2.0 GA 版本包括新增功能、特性增强、错误修复和文档更新。有关 3.2.0 版本所有变更的更多详细信息，请参阅 https://github.com/spring-projects/spring-kafka/releases/tag/v3.2.0。

即将发布的 Spring Boot 3.3.0 将包含 Spring for Apache Kafka 的 3.2.0 版本。

由于这是 3.2.x 系列的第一个 GA 版本，下面回顾一下 Spring for Apache Kafka 新一代版本中的所有增强和特性。

此版本使用 Kafka Client 3.7.0 版本，该版本引入了新的消费者组协议。这是 3.7.0 客户端中的一个早期访问功能，不应在生产环境中使用。目前，我们仅推荐将新消费者组协议用于测试目的。默认情况下，Spring for Apache Kafka 使用经典消费者，并且在测试新消费者组协议时，必须使用 group.protocol 消费者属性启用该协议。更多信息，请参阅此处。
这里有一个新的示例应用，展示了新消费者组协议的早期访问版本。
由于 KafkaClusterTestKit 中的某些限制，Embeddedkafka 中的 KRaft 模式默认是禁用的。如果有人想在 KRaft 模式下尝试 EmbeddedKafka，他们必须通过 EmbeddedKafka 上的 kraft 属性来启用它。此外，新的消费者组协议仅在 kraft 模式下工作，因此在测试此新协议时，由于上述 KafkaClusterTestKit 的限制，我们不建议在启用 kraft 模式的情况下使用 EmbeddedKafka。要测试新的消费者组协议，我们推荐使用 KRaft 模式下的真实 broker。更多信息，请参阅此处。
支持以编程方式在消费者上强制执行再平衡。
框架中对 Kafka Streams 支持的交互式查询新 API。
事务 ID 后缀的自定义。
在非阻塞重试中，提供一种基于异常类型路由到不同 DLT 的方式。
异步的 Kafka Listener 返回类型。
AfterRollbackProcessor 的改进，以跳过持续失败的整个记录批次。
类级别 @KafkaListener 支持非阻塞重试。更多详细信息请参阅此处
RetryTopicConfiguration 的改进
新 API 方法，用于根据用户提供的函数定位到偏移量。更多信息，请参阅参考文档。
@PartitionOffset 支持定位位置。
删除了 Spring for Apache Kafka 中许多特定于 Apache Kafka 的原生运行时提示，转而支持 graalvm-reachability-metadata 中的相同支持。