什么是新内容？

该版本要求 3.7.0 kafka-clients。 3.7.0 版本的 Kafka 客户端引入了新的消费者组协议。 有关详细信息及其限制，请参见 KIP-848。 新的消费者组协议是一个早期访问版本，不建议用于生产环境。 在本版本中仅建议用于测试目的。 因此，Spring for Apache Kafka 仅在与 kafka-client 本身提供的测试级别支持范围内支持此新的消费者组协议。 默认情况下，Spring for Apache Kafka 使用经典的消费者组协议；在测试新的消费者组协议时，需要通过 group.protocol 属性进行启用。spring-doc.cadn.net.cn

kraft 模式在 EmbeddedKafka 中默认被禁用，用户想要使用 kraft 模式必须启用它。 这是因为在 EmbeddedKafka 的 kraft 模式下观察到某些不稳定性，尤其是在测试新的消费者组协议时。 新的消费者组协议仅支持在 kraft 模式下，因此在测试新协议时，必须针对真实的 Kafka 集群，而不是基于 KafkaClusterTestKit 的那个，EmbeddedKafka 也是基于此。 此外，还观察到了一些在 KafkaListener 方法使用 EmbeddedKafka 的 kraft 模式时的竞态条件。 在这些问题解决之前，kraft 在 EmbeddedKafka 上的默认值将保持为 false。spring-doc.cadn.net.cn

一个新的API KafkaStreamsInteractiveQuerySupport，用于访问Kafka Streams交互查询中使用的可查询存储。 查看 Kafka Streams交互支持 了解更多信息。spring-doc.cadn.net.cn

新增了 TransactionIdSuffixStrategy 接口用于管理 transactional.id 后缀。 默认实现为 DefaultTransactionIdSuffixStrategy，当设置 maxCache 大于零时，可以在特定范围内复用 transactional.id，否则将通过递增计数器动态生成后缀。 有关更多信息，请参见 Fixed TransactionIdSuffix。spring-doc.cadn.net.cn

@KafkaListener（以及 @KafkaHandler）方法现在可以返回异步返回类型，包括 CompletableFuture<?>、Mono<?> 和 Kotlin 的 suspend 函数。 请参阅 异步返回 以获取更多信息。spring-doc.cadn.net.cn

现在可以在消息处理过程中根据抛出的异常类型将消息重定向到自定义死信队列（DLT）。 重定向规则可以通过RetryableTopic.exceptionBasedDltRouting或RetryTopicConfigurationBuilder.dltRoutingRules设置。 自定义死信队列以及其他重试和死信主题也会自动创建。 有关更多信息，请参阅基于抛出的异常将消息路由到自定义死信队列。spring-doc.cadn.net.cn

transactionManager 属性在 ContainerProperties 中已被弃用，建议使用 KafkaAwareTransactionManager ，这是一个比通用的 PlatformTransactionManager 更窄的类型。参见 ContainerProperties 和 事务同步。spring-doc.cadn.net.cn

一个新的AfterRollbackProcessor API processBatch 提供了。 请参阅 回滚处理器 以获取更多信息。spring-doc.cadn.net.cn

将@RetryableTopic属性SameIntervalTopicReuseStrategy的默认值更改为SINGLE_TOPIC。 参见单主题最大间隔指数延迟.spring-doc.cadn.net.cn

非阻塞重试支持 @KafkaListener 在类上。 请参见 非阻塞重试.spring-doc.cadn.net.cn

提供新的公共API以查找RetryTopicConfiguration。 见Find RetryTopicConfigurationspring-doc.cadn.net.cn

The RetryTopicConfigurer支持过程和注册MultiMethodKafkaListenerEndpoint。 The MultiMethodKafkaListenerEndpoint为属性defaultMethod和methods提供getter/setter。 修改仅适用于MethodKafkaListenerEndpoint类型的EndpointCustomizer。 The EndpointHandlerMethod添加新构造函数以构建提供的bean实例。 提供新的类EndpointHandlerMultiMethod来处理多方法重试端点。spring-doc.cadn.net.cn

ConsumerCallback 提供了一种新的API，可以根据用户定义的函数定位到指定偏移量，该函数将消费者的当前偏移量作为参数。 更多信息，请参阅 Seek API 文档。spring-doc.cadn.net.cn

添加了seekPosition属性到@PartitionOffset对TopicPartitionOffset.SeekPosition的支持。更多细节请参见手动分配。spring-doc.cadn.net.cn

TopicPartitionOffset现在有一个新的构造函数，该构造函数接受一个用户提供的函数来计算跳转到的位置。 当使用此构造函数时，框架会用当前消费者偏移位置作为输入参数调用该函数。 有关更多详细信息，请参见Seek API 文档。spring-doc.cadn.net.cn

对于定义了应用程序名称的Spring Boot应用，该名称现在被用作某些客户端类型自动生成客户端ID的默认前缀。 请参见默认客户端ID前缀以获取更多信息。spring-doc.cadn.net.cn