⭐ New Features
- Upgrade to Spring Kafka
3.8.0#3416 - Error handler throws an exception on blocking retries #3409
- Deserialization error for Acknowledgement in Spring Kafka Listener #3400
- Use the original key in reply messages when using ReplyingKafkaTemplate and SendTo #3395
🐞 Bug Fixes
- AnnotationEnhancer always return the old attributes #3425
- Incorrect JavaDoc for KafkaMessageHeaderAccessor.getBlockingRetryDeliveryAttempt() #3408
- KafkaAdmin clusterId configuration is ignored when observability is enabled and bootstrap supplier is not set #3402
- KafkaConsumer.close() no longer triggers the DefaultKafkaConsumerFactory.listener.removeConsumer() #3375
- Revise
AbstractConsumerSeekAware.onPartitionsAssigned()for concurreny #3373 - Fence the MessageLisnterContainer restart once the ConcurrentMessageListenerContainer is stopped #3371
- ConcurrentMessageListenerContainer isChildRunning API is returning false even though active MessageListenerContainer instances are processing messages. #3338
📔 Documentation
- Fix typos in the
EnableKafkaandtips.adoc#3412 - Fix retry topic documentation for class-level configuration #3396
🔨 Dependency Upgrades
- Bump org.springframework.retry:spring-retry from 2.0.7 to 2.0.8 #3437
- Bump org.junit:junit-bom from 5.11.0-RC1 to 5.11.0 #3436
- Bump org.springframework.data:spring-data-bom from 2024.0.2 to 2024.0.3 #3435
- Bump org.junit:junit-bom from 5.11.0-M2 to 5.11.0-RC1 #3405
- Bump kotlinVersion from 1.9.24 to 1.9.25 #3383
❤️ Contributors
Thank you to all the contributors who worked on this release: