The naming convention for DLT topics has been standardized to use the "-dlt" suffix consistently. This change ensures compatibility and avoids conflicts when transitioning between different retry solutions. Users who wish to retain the ".DLT" suffix behavior need to opt-in explicitly by setting the appropriate DLT name property.spring-doc.cn

A new method, getGroupId(), has been added to the ConsumerSeekCallback interface. This method allows for more selective seek operations by targeting only the desired consumer group. The AbstractConsumerSeekAware can also now register, retrieve, and remove all callbacks for each topic partition in a multi-group listener scenario without missing any. See the new APIs (getSeekCallbacksFor(TopicPartition topicPartition), getTopicsAndCallbacks()) for more details. For more details, see Seek API Docs.spring-doc.cn

RecordFilterStrategy now supports ignoring empty batches that result from filtering. This can be configured through overriding default method ignoreEmptyBatch(), which defaults to false, ensuring KafkaListener is invoked even if all ConsumerRecords are filtered out. For more details, see Message receive filtering Docs.spring-doc.cn

The ConcurentContainerMessageListenerContainer emits now a ConcurrentContainerStoppedEvent when all of its child containers are stopped. For more details, see Application Events and ConcurrentContainerStoppedEvent Javadocs.spring-doc.cn

When using ReplyingKafkaTemplate, if the original record from the request contains a key, then that same key will be part of the reply as well. For more details, see Sending Messages section of the reference docs.spring-doc.cn

When using DeadLetterPublishingRecovererFactory, the user applications can override the maybeLogListenerException method to customize the logging behavior.spring-doc.cn