What’s new?

此版本需要 3.7.0 kafka-clients。

一个用于访问 Kafka 流交互式查询中使用的可查询存储的新 API KafkaStreamsInteractiveQuerySupport。见 Kafka Streams Interactive Support 了解更多详情。

一个新的 TransactionIdSuffixStrategy 接口被用来管理 transactional.id 后缀。在 maxCache 设置大于零时，默认实现 DefaultTransactionIdSuffixStrategy 可以重新使用特定范围内的 transactional.id，否则会通过增加计数器来实时生成后缀。见 Fixed TransactionIdSuffix 了解更多信息。

@KafkaListener（以及 @KafkaHandler）方法现在能够返回异步返回类型，其中包括 CompletableFuture<?>、Mono<?> 和 Kotlin suspend 函数。请参阅 Async Returns 了解更多信息。

现在可以根据消息处理期间抛出的异常类型将消息重定向到自定义的 DLT。重定向规则通过 RetryableTopic.exceptionBasedDltRouting 或 RetryTopicConfigurationBuilder.dltRoutingRules 设置。自定义的 DLT 将被自动创建，就像其他重试和死信主题一样。见 Routing of messages to custom DLTs based on thrown exceptions 了解更多信息。

弃用 ContainerProperties 中的 transactionManager 属性，支持 KafkaAwareTransactionManager，与通用型 PlatformTransactionManager 相比是一个更小范围的类型。见 ContainerProperties 和 Transaction Synchronization。

提供了一个新 AfterRollbackProcessor API processBatch。见 After-rollback Processor 了解更多信息。

更改 @RetryableTopic 属性 SameIntervalTopicReuseStrategy 的默认值至 SINGLE_TOPIC。见 Single Topic for maxInterval Exponential Delay。

无阻塞重试支持 @"5"。请参阅 @"6"。

提供一个新的公开 API 来查找 RetryTopicConfiguration。见 Find RetryTopicConfiguration。

RetryTopicConfigurer 支持过程并注册 MultiMethodKafkaListenerEndpoint。MultiMethodKafkaListenerEndpoint 为属性 defaultMethod 和 methods 提供 getter/setter。仅严格针对 MethodKafkaListenerEndpoint 类型修改 EndpointCustomizer。EndpointHandlerMethod 添加了新的构造函数，用于为提供的 bean 构造一个实例。提供新的类 EndpointHandlerMultiMethod 来处理用于重试端点的多方法。

ConsumerCallback 提供了一项新 API 来根据用户自定义函数查找一个偏移，该函数将消耗者中当前的偏移作为参数。见 Seek API Docs 了解更多详情。

TopicPartitionOffset 有一个新的构造函数，用来生成用于计算要查找的偏移量的用户提供函数。当使用这个构造函数时，框架会用当前消耗者偏移位置的输入参数来调用函数。见 Seek API Docs 了解更多详情。

对于定义了应用程序名称的 Spring Boot 应用程序，这个名称现在用作某些客户端类型的自动生成的客户端 ID 的默认前缀。见 Default client ID prefixes 了解更多详情。