新增功能

此版本需要 3.7.0 。 3.7.0 版本的 Kafka 客户端引入了新的消费组协议。 有关更多详细信息及其限制，请参阅 KIP-848。 新的使用者组协议是早期访问版本，不打算在生产中使用。 在此版本中，仅建议用于测试目的。 因此， Spring for Apache Kafka 仅在其本身可用的此类测试级别支持的范围内支持这种新的消费者组协议。 默认情况下， Spring for Apache Kafka 使用经典的消费者组协议，并且在测试新的消费者组协议时，需要通过消费者上的属性选择加入。kafka-clientskafka-clientgroup.protocolspring-doc.cn

默认情况下，该模式处于禁用状态，想要使用该模式的用户必须启用它。 这是由于在使用 in 模式时观察到某些不稳定性，尤其是在测试新的使用者组协议时。 新的消费者组协议仅在 模式下受支持，因此，在测试新协议时，需要针对真实的 Kafka 集群进行，而不是基于的 Kafka 集群。 此外，在使用 in 模式运行多个方法时，还观察到一些其他争用条件。 在这些问题得到解决之前，默认值 on 将保持为 。kraftEmbeddedKafkakraftEmbeddedKafkakraftkraftKafkaClusterTestKitEmbeddedKafkaKafkaListenerEmbeddedKafkakraftkraftEmbeddedKafkafalsespring-doc.cn

用于访问 Kafka Streams 交互式查询中使用的可查询存储的新 API。 有关更多详细信息，请参阅 Kafka Streams Interactive Support 。KafkaStreamsInteractiveQuerySupportspring-doc.cn

引入了一个新接口来管理 suffix。 默认实现是当设置大于零可以在特定范围内重复使用时，否则将通过递增计数器来动态生成后缀。 有关更多信息，请参阅Fixed TransactionIdSuffix。TransactionIdSuffixStrategytransactional.idDefaultTransactionIdSuffixStrategymaxCachetransactional.idspring-doc.cn

@KafkaListener（和 ） 方法现在可以返回异步返回类型 include 和 Kotlin 函数。 有关更多信息，请参阅 Async Returns 。@KafkaHandlerCompletableFuture<?>Mono<?>suspendspring-doc.cn

现在可以根据异常的类型将消息重定向到自定义 DLT，该异常在消息处理过程中引发。 重定向规则通过 或 设置。 自定义 DLT 以及其他重试和死信主题会自动创建。 有关更多信息，请参阅根据引发的异常将消息路由到自定义 DLT。RetryableTopic.exceptionBasedDltRoutingRetryTopicConfigurationBuilder.dltRoutingRulesspring-doc.cn

弃用属性以支持 ，与一般类型相比，这是一种更窄的类型。请参阅 ContainerProperties 和事务同步。transactionManagerContainerPropertiesKafkaAwareTransactionManagerPlatformTransactionManagerspring-doc.cn

提供了新的 API。 有关更多信息，请参阅 After-rollback Processor 。AfterRollbackProcessorprocessBatchspring-doc.cn

将属性默认值更改为 。 请参阅 maxInterval Exponential Delay 的单个主题。@RetryableTopicSameIntervalTopicReuseStrategySINGLE_TOPICspring-doc.cn

非阻塞重试支持对 Class 进行@KafkaListener。 请参阅 Non-blocking Retries。spring-doc.cn

提供新的公共 API 以查找 。 请参阅 查找 RetryTopicConfigurationRetryTopicConfigurationspring-doc.cn

支持流程和注册 . 为 properties 和 . 严格修改 that for types。 add new 构造函数为提供的 bean 构造一个实例。 提供用于重试端点的 handler 多方法的新类。RetryTopicConfigurerMultiMethodKafkaListenerEndpointMultiMethodKafkaListenerEndpointgetter/setterdefaultMethodmethodsEndpointCustomizerMethodKafkaListenerEndpointEndpointHandlerMethodEndpointHandlerMultiMethodspring-doc.cn

ConsumerCallback提供了一个新的 API，用于根据用户定义的函数查找偏移量，该函数将使用者中的当前偏移量作为参数。 有关更多详细信息，请参阅 Seek API Docs 。spring-doc.cn

添加属性以支持 . 有关更多详细信息，请参阅 manual-assignment 。seekPosition@PartitionOffsetTopicPartitionOffset.SeekPositionspring-doc.cn

TopicPartitionOffset具有一个新的构造函数，该构造函数采用用户提供的函数来计算要查找的偏移量。 使用此构造函数时，框架使用当前使用者偏移位置的 input 参数调用函数。 有关更多详细信息，请参阅 Seek API Docs 。spring-doc.cn

对于定义应用程序名称的 Spring Boot 应用程序，现在使用此名称 作为某些客户端类型的自动生成的客户端 ID 的默认前缀。 有关更多详细信息，请参阅默认客户端 ID 前缀。spring-doc.cn