Bump org.springframework.kafka:spring-kafka from 2.8.5 to 2.9.11

[renovate-pagopa]

This PR contains the following updates:

Package	Change	Age	Confidence
org.springframework.kafka:spring-kafka	2.8.5 -> 2.9.11

For further information on security, please refer to the Confluence page link

---

Release Notes

spring-projects/spring-kafka (org.springframework.kafka:spring-kafka)

v2.9.11

Compare Source

⭐ 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

v2.9.10

Compare Source

⭐ 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

v2.9.9

Compare Source

🐞 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

v2.9.8

Compare Source

⭐ New Features

• Support Dynamic Micrometer Tags Based on Consumer/Producer Record #​2649

🐞 Bug Fixes

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

🔨 Dependency Upgrades

• Upgrade Spring Framework, Data, Reactor, Micrometer Versions #​2656

External Links

• Reference Documentation

v2.9.7

Compare Source

🐞 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

v2.9.6

Compare Source

⭐ 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

v2.9.5

Compare Source

⭐ 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

v2.9.4

Compare Source

🐞 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

v2.9.3

Compare Source

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

v2.9.2

Compare Source

Change log:

6b938e4 Upgrade Versions; Prepare for Release
e455431 GH-2438: RetryTopic Destination Partition Select
58aa8b1 GH-2432: Remove Unnecessary Variable
9850af5 GH-2432: Fix Retryable Topic Provisioning
cb5c36b GH-2410: Disallow nack() with Out of Order Commits
91507a9 Update config example type in doc
c69791e Add Acknowledgment.nack() variants accepting Duration
43bc67a Fix Race In Test
3850a01 GH-2419: DLPR: Protect Against Non-Compliant PF
5c776cd GH-2387: Fix FallbackBatchErrorHandler Events
7c648d7 Don't Use kafka.common.KafkaException in Broker
766333c GH-2415: Doc for DeserializationEx... with DLPR
8ad588e GH-2395: RetryListener - Add Batch Methods
f584d8f Upgrade Apache Kafka to 3.2.3
5fed903 GH-2400: ReplyingKT Improve CorrelationId Logging

v2.9.1

Compare Source

Change log:

fabdcb7 Upgrade Versions; Prepare for Release
5efa335 Upgrade Apache Kafka to 3.2.2
4fdedd7 GH-2184: Don't Log KafkaBackoffException
8336461 Deprecate ListenableFuture Callback Extensions
ea6fa8f Add Missing Pause/Resume Events
781e726 GH-2382: Fix Unchecked Cast in Test
2eacf7a Remove Another Dead Link from Change History
8f6fd87 Remove Dead Links from Change History
7da485a Fix Duplicate Doc Anchors
f9419c2 Fix typo in whats-new.adoc
6a28cc5 GH-2382: Fix FBEH Cross Talk
798dea3 GH-2375: Add KLER.unregisterListenerContainer
90c6e95 GH-2357: Remove Remaining Uses of ListenableFuture

v2.9.0

Compare Source

Change log:

7a3223d Upgrade Versions; Prepare for Release
295b68c GH-2357: Fix Sonar Issues
128372f GH-2357: Switch to CompletableFuture
a4ee066 GH-2355: Add ManualAckListenerErrorHandler (#​2356)
e682c87 GH-2350: Fix Paused Partitions After Rebalance
2732303 GH-2344: AggReplyingKT Support Custom Correlation
b1d97b9 GH-2345: Fix Possible NPE in KafkaAdmin
4e6d59c Sonar Fixes
e579c62 Fix for Java 8 compatibility
dd981e1 GH-2239: Fix Boot AutoConfiguration
15e5668 GH-2340: Fix Retrying Batch Error Handling
e220b17 Sonar Fixes
11e03c9 GH-2262: Fix Possible NPE
f7cbbfe Sonar Fixes

v2.8.11

Compare Source

Change log:

e31e639 Upgrade Versions; Prepare for Release
5df71c1 Fix Missing Re-Interrupt
a9b0252 Revert KafkaAdmin Change (Previous Commit)
8c2b325 Fix Missing Re-Interrupts
6ec1b3b GH-2459: FallbackBatchErrorHandler Retryable Ex
48b2017 GH-2451: Fix Class Level Listener Multi Instances

v2.8.10

Compare Source

Change log:

e021e32 Upgrade Versions; Prepare for Release
bd146f6 GH-2432: Remove Unnecessary Variable
6a253f2 GH-2432: Fix Retryable Topic Provisioning
950a2ea GH-2410: Disallow nack() with Out of Order Commits
0547dc7 Update config example type in doc
a03f67b Fix Race In Test
5bd08c0 GH-2419: DLPR: Protect Against Non-Compliant PF
f6cbf11 GH-2387: Fix FallbackBatchErrorHandler Events
2e1feb3 Don't Use kafka.common.KafkaException in Broker
34c48f5 GH-2415: Doc for DeserializationEx... with DLPR
5df2568 Fix previous commit conflicts
8cfd1d8 GH-2395: RetryListener - Add Batch Methods

v2.8.9

Compare Source

Change log:

48334e4 Upgrade Reactor Version
269fd79 Upgrade Versions; Prepare for Release
8193cd2 Upgrade Apache Kafka to 3.0.2
a190ba7 Add Missing Pause/Resume Events
e1bb194 GH-2382: Fix Unchecked Cast in Test
e4eedb7 Remove Another Dead Link from Change History
6d72816 Remove Dead Links from Change History
f3837a1 Fix Duplicate Doc Anchors
3de1e89 GH-2382: Fix RetryingBatchErrorHandler Cross Talk
f001423 GH-2375: Add KLER.unregisterListenerContainer
b6b4c1a GH-2363: Fix Class Cast in ErrorHandlerAdapter

v2.8.8

Compare Source

Change log:

16fbdde Upgrade Versions; Prepare for Release
e94985b GH-2350: Fix Paused Partitions After Rebalance
f1f200c GH-2344: AggReplyingKT Support Custom Correlation
f747329 GH-2345: Fix Possible NPE in KafkaAdmin
dee71ae GH-2340: Fix Retrying Batch Error Handling
3f30673 GH-2288: Delegating EH - Traverse Causes
4b93cdf KafkaAdmin: fix usage of the Map.of()
989fb29 GH-2332: Fix Container.pause() with Manual Assign.
b286250 GH-2335: Fix RetryTopic Cause Header Name
3eb5d9f Fix Doc Copyright
fea092c transactionIdPrefix Doc Polishing
bdb7e84 Polish Container setTransactionManager Javadocs
46c63e2 GH-2321: Support Inbound Header Mapping Matchers
558c19f GH-2318: ReplyingKT - Wait for Assignment
e49d850 Fix Possible Race in KafkaAdmin
d1b60d2 Widen Delegate Type for KafkaBackoffAwareMLAdapter

v2.8.7

Compare Source

Change log:

c93304a Upgrade Versions; Prepare for Release
9675989 Update Gradle Enterprise plugin
4bce526 GH-2306: Improve DeserEx Message For Improper Ex.
168b9d2 Add Converter Factories to Method Factory
273416c GH-2304: Fix SendTo on Interface Etc.
1d60eda GH-2297: Add KLERegistry.alwaysStartAfterRefresh
e88711f GH-1482: Make Topic Config Update Optional
ec2608b GH-1482: Support Admin.incrementalAlterConfigs
a1f112c Add Acknowledgment.nack() variants accepting Duration
a9a19a7 GH-2295: No Resolvers with ConsumerRecordMetadata
23a103e Log Uncommitted After Rebalance
1e82ac9 GH-2292: Doc - Fix Container Factory Generics
5101b17 GH-2286: Doc Fixes
07e4bc8 Precise unit for sleep duration and wake time
388b23f GH-2148: Use ObjectProvider to Locate MeterRegistry
ba309fb GH-2274: Option to Not Configure (De)serializers

v2.8.6

Compare Source

Change log:

7f5395d Upgrade Versions; Prepare for Release
041ce86 GH-2269: Improve DLPR Extensibility
6e92b7f GH-2252: Keep offset metadata in case of batch reprocessing (#​2253)
9a36d9b GH-2128: More Doc Polishing
1708bf4 GH-2249: Batch Listener LISTENER_INFO Headers
fc544cd GH-2128: Document Nack Sleep Time Limitations
60c8f6c Add JUnit5 params Module to Build
f90c8e1 GH-2240: Bug fix for KafkaTemplate.receive(..)
63e56a7 Fix Sonar Issue
34e1950 Make artifactoryPublish dependsOn build
fe74dbf Revert "Make artifactoryPublish depend on build"

---

Configuration

📅 Schedule: Branch creation - "" (UTC), Automerge - At any time (no schedule defined).

🚦 Automerge: Disabled by config. Please merge this manually once you are satisfied.

♻ Rebasing: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox.

👻 Immortal: This PR will be recreated if closed unmerged. Get config help if that's undesired.

---

• If you want to rebase/retry this PR, check this box

---

This PR has been generated by Renovate Bot.

[changeset-bot]

⚠️ No Changeset found

Latest commit: 2763723

Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. If these changes should result in a version bump, you need to add a changeset.

This PR includes no changesets

When changesets are added to this PR, you'll see the packages that this PR includes changesets for and the associated semver types

Click here to learn what changesets are, and how to add one.

Click here if you're a maintainer who wants to add a changeset to this PR

[codecov-commenter]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 56.95%. Comparing base (e989c5b) to head (a3f983f).
Report is 239 commits behind head on main.

Additional details and impacted files

@@            Coverage Diff             @@
##             main     #304      +/-   ##
==========================================
+ Coverage   52.45%   56.95%   +4.50%     
==========================================
  Files         157      215      +58     
  Lines        8036    11165    +3129     
  Branches      683      917     +234     
==========================================
+ Hits         4215     6359    +2144     
- Misses       3755     4769    +1014     
+ Partials       66       37      -29     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
• 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.