新增功能

DLT 主题的命名约定已标准化，以始终使用“-dlt”后缀。此更改可确保兼容性，并避免在不同重试解决方案之间转换时发生冲突。希望保留 “.DLT“后缀行为需要通过设置适当的 DLT name 属性来显式选择加入。spring-doc.cn

新方法 已添加到界面中。 此方法通过仅针对所需的使用者组来允许进行更具选择性的查找操作。 现在，还可以在多组侦听器场景中注册、检索和删除每个主题分区的所有回调，而不会丢失任何回调。 有关更多详细信息，请参阅新的 API （， ）。 有关更多详细信息，请参阅 Seek API 文档。getGroupId()ConsumerSeekCallbackAbstractConsumerSeekAwaregetSeekCallbacksFor(TopicPartition topicPartition)getTopicsAndCallbacks()spring-doc.cn

RecordFilterStrategy现在支持忽略筛选产生的空批处理。 这可以通过覆盖 default method 来配置，该方法默认为 false，确保即使过滤掉所有方法也调用。 有关更多详细信息，请参阅 消息接收过滤 文档。ignoreEmptyBatch()KafkaListenerConsumerRecordsspring-doc.cn

现在，当其所有子容器都停止时，会发出 a。 有关更多详细信息，请参阅应用程序事件和 Javadocs。ConcurentContainerMessageListenerContainerConcurrentContainerStoppedEventConcurrentContainerStoppedEventspring-doc.cn

使用 时，如果请求中的原始记录包含键，则该键也将是回复的一部分。 有关更多详细信息，请参阅参考文档的发送消息部分。ReplyingKafkaTemplatespring-doc.cn

使用 时，用户应用程序可以覆盖该方法以自定义日志记录行为。DeadLetterPublishingRecovererFactorymaybeLogListenerExceptionspring-doc.cn

扩展时，用户应用程序可能会覆盖自定义 Admin 客户端创建的方法。KafkaAdmincreateAdminspring-doc.cn

使用时，现在可以通过覆盖该方法来返回对象的自定义实现。KafkaStreamsCustomizerKafkaStreamsinitKafkaStreamsspring-doc.cn

使用 时，可以在其 headers 字段中包含 header。 如果 设置为 error handler 作为重试侦听器，则每个都有 delivery attempt 标头。 有关更多详细信息，请参阅适用于 Batch Listener 的 Kafka 标头。BatchListenerConsumerRecordKafkaHeaders.DELIVERY_ATTMPTDeliveryAttemptAwareRetryListenerConsumerRecordspring-doc.cn

的 和 现在可以使用 . 有关更多信息，请参阅 JavaDocs 和 Micrometer Support 。MicrometerProducerListenerMicrometerConsumerListenerKafkaStreamsMicrometerListenerTaskSchedulerKafkaMetricsSupportspring-doc.cn