v3.0.11

🐞 Bug Fixes

• Fix Invalid Warning Log With Non-Blocking Retries #2784
• ParseStringDeserializer throws NullPointerException when message is null #2779

External Links

• Reference Documentation

v2.9.12

🐞 Bug Fixes

• Fix Invalid Warning Log With Non-Blocking Retries #2787
• ParseStringDeserializer throws NullPointerException when message is null #2783

External Links

• Reference Documentation

v3.0.10

⭐ New Features

• Private Header Type for DeserializationExceptions #2770
• Add KafkaMessageHeaderAccessor #2767
• Consider to expose a spring.kafka.bootstrap-servers System property with EmbeddedKafkaBroker #2750
• Partial positive acknowledge support for BatchAcknowledgingMessageListener #2066

🐞 Bug Fixes

• AdminClient doesn't use configured properties while starting a container listener #2762
• Sync Gradle .module Files to Maven #2753

🔨 Dependency Upgrades

• Upgrade Jackson, Micrometer, Reactor, Spring Data Versions #2778
• Upgrade Gradle, SonarQub, Jacoco, NoHttp Versions #2758

🔨 Tasks

• Add ConfigFile Runtime Hint (for JAAS) #2772
• Implement Lifecycle in DefaultKafkaProducerFactory #2760
• Clean Up Gradle Enterprise Config #2757
• Refactor DeserializationException Detection Code #2756

External Links

• Reference Documentation

v2.9.11

⭐ New Features

• Private Header Type for DeserializationExceptions #2771

🐞 Bug Fixes

• AdminClient doesn't use configured properties while starting a container listener #2764

🔨 Dependency Upgrades

• Upgrade Micrometer, Reactor, Spring Data Versions #2777

External Links

• Reference Documentation

v3.0.9

⭐ New Features

• FallbackBatchErrorHandler - Consider Seeking and Exiting Retries When Container is Paused #2742
• Make KafkaAdmin Easier to Subclass and Add a Filter Mechanism #2720
• GH-2709: Preserve existing JAAS configuration #2713
• Add DLPR Creator Function to DeadLetterPublishingRecovererFactory #2711

🐞 Bug Fixes

• Possible dead lock between DefaultKafkaProducerFactory.expire and DefaultKafkaProducerFactory.removeProducer #2744
• GH-2738: Pausing container results in WakeupException without retrying failed listener invocation #2739
• NullPointerException in KafkaRecordReceiverContext #2736
• Fix Race Condition in DelegatingInvocableHandler #2723
• Behavior Change When Interceptor Throws an Exception #2722

📔 Documentation

• Fix typo in BackOffValuesGenerator #2741
• Minor typo in Handling Exceptions section of docs #2716

🔨 Dependency Upgrades

• Upgrade Spring Framework, Data, Micrometer, Reactor Versions #2746

❤️ Contributors

Thank you to all the contributors who worked on this release:

@WhiteDG, @antonio-tomac, and @edanidzerda

External Links

• Reference Documentation

v2.9.10

⭐ New Features

• Make KafkaAdmin Easier to Subclass and Add a Filter Mechanism #2726
• GH-2709: Preserve existing JAAS configuration #2718
• Auto Config Non-Blocking Retries with asyncAcks #2707

🐞 Bug Fixes

• Possible dead lock between DefaultKafkaProducerFactory.expire and DefaultKafkaProducerFactory.removeProducer #2748
• Pausing container results in WakeupException without retrying failed listener invocation #2740
• Behavior Change When Interceptor Throws an Exception #2728
• Fix Race Condition in DelegatingInvocableHandler #2725

🔨 Dependency Upgrades

• Upgrade Spring Framework, Data, Micrometer, Reactor Versions #2745

❤️ Contributors

Thank you to all the contributors who worked on this release:

@antonio-tomac and @edanidzerda

External Links

• Reference Documentation

v3.0.8

⭐ New Features

• MMConverter Support Custom Partition Selection #2703
• Auto Config Non-Blocking Retries with asyncAcks #2702
• Consider providing custom KafkaSender to ReactiveKafkaProducerTemplate #2190

🐞 Bug Fixes

• Default Empty Map for PF configurationProperties #2700
• Incompatible with @Nested class test #2692

📔 Documentation

• Non-Blocking Retries don't work with BatchListener #2699
• Fixed Typo #2698
• docs: fix Javadoc of CommonErrorHandler::remainingRecords #2691
• docs: fix name of overriden method #2684

🔨 Dependency Upgrades

• Upgrade Spring Framework, Data, Retry, Micrometer, Reactor Versions #2710

❤️ Contributors

Thank you to all the contributors who worked on this release:

@rajadilipkolli, @sculeb, and @tbcs

External Links

• Reference Documentation

v3.0.7

⭐ New Features

• Add MockProducerFactory and MockConsumerFactory #2673
• Better exception message header for DLT #2671

🐞 Bug Fixes

• Fix CommonErrorHandler for asyncAcks and AckMode.MANUAL #2677
• Fix Race in Micrometer Test #2661

📔 Documentation

• Howewever -> However #2670

🔨 Dependency Upgrades

• Upgrade Spring Framework, Data, Reactor, Micrometer Versions #2682

🔨 Tasks

• Expose user exception thrown during rebalance #2667
• Remove duplicate native hint registration. #2659

❤️ Contributors

Thank you to all the contributors who worked on this release:

@MatejNedic and @michaldo

External Links

• Reference Documentation

v2.9.9

🐞 Bug Fixes

• Fix CommonErrorHandler for asyncAcks and AckMode.MANUAL #2679
• Fix Race in Micrometer Test #2662

🔨 Dependency Upgrades

• Upgrade Spring Data, Micrometer Versions #2681

External Links

• Reference Documentation

v3.0.6

⭐ New Features

• GH-2638: Support Dynamic Tags via Observation #2650
• Support Dynamic Micrometer Tags Based on Consumer/Producer Record #2638

🐞 Bug Fixes

• Races in KafkaListenerAnnotationBeanPostProcessor on scope=prototype bean instantiation #2642
• "resetStateOnExceptionChange" has no effect, because the cause of "ListenerExecutionFailedException" is always a "TimestampedException" #2641

📔 Documentation

• Missing upgrade section in the documentation for KafkaHeaders changes #2640

🔨 Dependency Upgrades

• Upgrade Spring Framework, Data, Micrometer, Reactor, JUnit Versions #2657

External Links

• Reference Documentation