有什么新鲜事？

DLT主题的命名规范已被标准化，一致使用“-dlt”后缀。这一变化确保了兼容性，并避免了在不同重试解决方案之间切换时的冲突。希望保留“.”的用户DLT“后缀行为需要通过设置相应的DLT名称属性来明确选择加入。spring-doc.cadn.net.cn

一种新方法，getGroupId（），已被添加到消费者寻求回叫接口。 该方法通过仅针对目标消费者群体，实现更具选择性的寻道作。 这摘要消费者寻求感知现在还可以在多组监听器场景中注册、检索和移除每个主题分区的所有回调，而不会遗漏任何回调。请参见新的API（getSeekCallbacksFor（TopicPartition topicPartition）,getTopicsAndCallbacks（））以获取更多细节。欲了解更多详情，请参见Seek API文档。spring-doc.cadn.net.cn

RecordFilterStrategy现在支持忽略因过滤产生的空批次。这可以通过覆盖默认方法进行配置ignoreEmptyBatch（），默认为false，确保卡夫卡听众即使所有消费者唱片已被过滤掉。更多细节请参见“消息接收过滤文档”。spring-doc.cadn.net.cn

这ConcurentContainerMessageListenerContainer现在发出ConcurrentContainerStoppedEvent当所有子容器都被停止时。更多细节请参见应用事件和ConcurrentContainerStoppedEventJavadocs。spring-doc.cadn.net.cn

使用回复Kafka模板，如果请求的原始记录包含密钥，那么该密钥也会成为回复的一部分。更多细节请参见参考文档中的“发送消息”部分。spring-doc.cadn.net.cn

使用死信出版恢复者工厂，用户应用程序可以覆盖可能LogListenerException自定义日志行为的方法。spring-doc.cadn.net.cn

延伸时卡夫卡管理员，用户应用程序可以覆盖创建管理员自定义管理员客户端创建的方法。spring-doc.cadn.net.cn

使用KafkaStreamsCustomizer现在可以返回自定义实现卡夫卡流通过覆盖initKafkaStreams方法。spring-doc.cadn.net.cn

当使用批处理监听器这消费者记录可以有KafkaHeaders.DELIVERY_ATTMPT其首部字段中的首部。如果DeliveryTryAwareRetryListener设置为错误处理程序作为重试监听器，每个消费者记录具有投递尝试的头部。更多细节请参见 Kafka 批处理听取者头。spring-doc.cadn.net.cn

这MicrometerProducerListener,MicrometerConsumerListener和KafkaStreamsMicrometerListener现在可以配置为任务调度器. 看KafkaMetricsSupport更多信息请参见JavaDocs和Micrometer支持。spring-doc.cadn.net.cn