有什么新鲜事？

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