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