Apache Kafka 版 Spring 3.2.0、3.1.5 和 3.0.17 现已推出

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

代表团队和社区中做出贡献的每个人，我们很高兴地宣布 Apache Kafka 版 Spring 3.2.0 正式可用。

Apache Kafka 版 Spring 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 将包含 Apache Kafka 版 Spring 的 3.2.0 版本。

由于这是 3.2.x 系列中的第一个 GA 版本，因此以下是包含在此新一代 Apache Kafka 版 Spring 中的所有增强功能和功能的概览。

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