v2.9.7

🐞 Bug Fixes

• Deadlock on lifecycleMonitor #2630
• Reclassify Exception in FallbackBatchErrorHandler When Exception Changes #2623
• Spring Kafka Listener uses stale oauthbearer token, fails to connect after initial token expired. #2614
• Synchronized kafka transaction is not committed nor rolled back when code from custom "afterCommit" throws exception #2606
• Spring Messaging batch payload incompatible with Kotlin #2603
• KafkaMessageListenerContainer pauses for a long time after error handling #2598

🔨 Dependency Upgrades

• Upgrade Spring Framework to 5.3.26 #2633

External Links

• Reference Documentation

v3.0.4

⭐ New Features

• spring-kafka-test does not work with spring native graalvm #2582
• GH-2496: Reuse retry topic for maxInterval delay #2497
• Feature Request: Provide DestinationTopic.Properties#isRetryTopic() method #2377

🐞 Bug Fixes

• Synchronized kafka transaction is not commited nor rolled back when code from custom "afterCommit" throws exception #2604
• Spring Messaging batch payload incompatible with Kotlin #2600
• KafkaMessageListenerContainer pauses for a long time after error handling #2596

📔 Documentation

• Updated README.md #2594

🔨 Dependency Upgrades

• Upgrade Spring Framework, Reactor Versions #2607

❤️ Contributors

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

@esivakumar18 and @jgslima

External Links

• Reference Documentation

v3.0.3

⭐ New Features

• Allow to use KafkaListenerContainerFactory with custom message converter for batch and record listeners #2566
• Repeating headers in Non-Blocking Retry Mechanism #2549

🐞 Bug Fixes

• ProducerFactory's argument txIdPrefix of createProducer not marked as @Nullable #2583
• Container Does Not Pause for Missing Acks After a Rebalance #2581
• Non-blocking retries: partition rebalance causes emergency consumer stop #2576
• NPE in FailedBatchProcessor if Reported Index is Out of Bounds #2558
• An application using default spring boot configuration fails at the startup when there are multiple @KafkaListener with @RetryableTopic #2554

📔 Documentation

• The documentation of the autoFlush seems to be confusing (to me) #2562
• GH-2516: Fix code example in the documentation for for Non-Blocking Retries - DLT Failure Behavior #2517

🔨 Dependency Upgrades

• Upgrade Jackson, Micrometer, Reactor, Spring Data, Spring Framework Versions #2592
• Upgrade to Apache Kafka 3.3.2 #2552

🔨 Tasks

• Update Gradle Enterprise plugin #2578

❤️ Contributors

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

@jprinet and @jucosorin

External Links

• Reference Documentation

v2.9.6

⭐ New Features

• GH-2566: Both Converters in Container Factory #2570
• Repeating headers in Non-Blocking Retry Mechanism #2551

🐞 Bug Fixes

• Container Does Not Pause for Missing Acks After a Rebalance #2587
• ProducerFactory's argument txIdPrefix of createProducer not marked as @Nullable #2585
• Non-blocking retries: partition rebalance causes emergency consumer stop #2580
• GH-2565: Topic partition is not resumed for RetryTopic #2569
• GH-2558: Fix Possible NPE in FailedBatchProcessor #2560
• The RetryTopicBeanNames.DEFAULT_SCHEDULER_WRAPPER_BEAN_NAME accidentally points to defaultRetryTopicKafkaTemplate #2557

📔 Documentation

• Update Docs For Overriding Boot Dependencies #2564
• GH-2516: Fix code example in the documentation for for Non-Blocking Retries - DLT Failure Behavior #2556

🔨 Dependency Upgrades

• Upgrade Jackson, Micrometer, Reactor, Spring Data Versions #2591

❤️ Contributors

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

@cenkakin and @jucosorin

External Links

• Reference Documentation

v3.0.2

⭐ New Features

• GH-2542: FallbackBatchErrorHandler Improvement #2543
• Add possibility to remove custom headers in method: addHeadersFunction(...) from DeadLetterPublishingRecoverer #2528
• Cluster Id: Use Producer/Consumer Bootstrap Servers if Different to the Context's KafkaAdmin Servers #2505

🐞 Bug Fixes

• Get Cluster Id for Observation Lazily #2538
• Topic partition is not resumed after re-assignment for RetryTopic #2525
• KafkaListener Regression - Pseudo Bean __listener Not Available in the Id Attribute #2521

📔 Documentation

• Remove outdated information for transactional.id #2524
• GH-2511: Fix code examples in the documentation for for Non-Blocking Retries - BackOff Configuration #2512

🔨 Dependency Upgrades

• Upgrade Spring, Micrometer, Reactor Versions #2548

🔨 Tasks

• kafka-clients 3.3.2 Compatibility #2540
• Refactor Switch Expressions #2535
• Upgrade Samples to 3.0.x #2508

❤️ Contributors

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

@LukasHeimann, @jucosorin, and @truepele

External Links

• Reference Documentation

v2.9.5

⭐ New Features

• GH-2542: FallbackBatchErrorHandler Improvement #2544
• Add possibility to remove custom headers in method: addHeadersFunction(...) from DeadLetterPublishingRecoverer #2530

🐞 Bug Fixes

• Topic partition is not resumed after re-assignment for RetryTopic #2534

📔 Documentation

• GH-2511: Fix code examples in the documentation for for Non-Blocking Retries - BackOff Configuration #2513

🔨 Dependency Upgrades

• Upgrade Spring, Micrometer, Reactor Versions #2547

🔨 Tasks

• kafka-clients 3.3.2 Compatibility #2541

❤️ Contributors

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

@jucosorin and @truepele

External Links

• Reference Documentation

v3.0.1

⭐ New Features

• Add Option to Set Listener Thread Name #2501

🐞 Bug Fixes

• Error on executing tests with spring-kafka-test 3.0.0 #2490
• Duplicate consumption triggered by consumer group rebalance #2489

📔 Documentation

• Document Parameter Annotation Limitations #2499

🔨 Dependency Upgrades

• Upgrade Spring Framework (6.0.3), Micrometer (1.10.2), Reactor (2022.0.1) #2507

❤️ Contributors

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

@mikael-carlstedt

v2.9.4

🐞 Bug Fixes

• Duplicate consumption triggered by consumer group rebalance #2492

📔 Documentation

• Fix Consumer Thread Naming Documentation #2504
• Document Parameter Annotation Limitations #2500

❤️ Contributors

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

@mikael-carlstedt

v3.0.0

⭐ New Features

• Make RetryTopicConfigurationSupport initialize RetryTopicComponentFactory lazily #2478
• Use isEmpty() Instead of size(); toList() #2474
• Add spring-kafka-bom #2472
• suggestion: change @RetryableTopic replicationFactor default to -1 (broker default) #2471

🐞 Bug Fixes

• Disable Global Embedded Kafka Support if JUnit Platform is < 1.8 #2481
• java.lang.IllegalStateException: Only one 'RetryTopicConfigurationSupport' is allowed when Spring context is reloaded #2477

📔 Documentation

• Docs for Native Images #2483

🔨 Dependency Upgrades

• Spring Data 2022.0.0, Retry 2.0.0, Framework 6.0.0 #2488
• Hibernate Validation 8.0.0-final, Micrometer 1.10.1, Mockito 4.8.1, Reactor 2022.0.0 #2487
• Micrometer 1.10.0, Tracing, Docs 1.0.0 #2486
• Upgrade to Jackson 2.14.0 #2485

v2.9.3

Change log:

5a412d8 Upgrade Versions; Prepare for Release
91ac6d2 GH-2477: Fix Static State RetryTopicConfigSupport
8c15f7d Fix Missing Re-Interrupt
42f654d Revert KafkaAdmin Change (Previous Commit)
30d2b89 Fix Missing Re-Interrupts
65bbdb6 Add KafkaTestUtils methods using Duration for timeout (2.9) (#2468)
c92ec76 GH-2464: Fix Delivery Attempt Header (Rare)
921e6ae GH-2459: Resolve Sonar Issues
f9f6a55 @RetryableTopic More SpEL Support
5c70ec1 GH-2459: FallbackBatchErrorHandler Retryable Ex
2966c7d GH-2451: Fix Class Level Listener Multi Instances
9e07035 GH-2352: Fix Doc Typo
2bf7d62 GH-2352: Expose KLERegistrar Getter on BPP