fix(deps): update dependency org.springframework.kafka:spring-kafka to v3

[renovate]

This PR contains the following updates:

Package	Change	Age	Adoption	Passing	Confidence
org.springframework.kafka:spring-kafka	2.9.13 -> 3.1.4

---

Release Notes

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

v3.1.4

🐞 Bug Fixes

• Duplicate record consumption due to offset decrease in last offset commit #​3190
• Setting the Kafka Streams property default.dsl.store has no effect #​3181
• BatchInterceptor is not working properly with retries #​3170
• MDCs are missing in logs produced by DefaultErrorHandler. #​3154
• In kafka events, the traceId and spanId are not written in the logs #​3149

🔨 Dependency Upgrades

• Bump org.springframework.data:spring-data-bom from 2023.1.4 to 2023.1.5 #​3201
• Bump org.springframework:spring-framework-bom from 6.1.5 to 6.1.6 #​3200
• Bump io.micrometer:micrometer-bom from 1.12.4 to 1.12.5 #​3199
• Bump io.micrometer:micrometer-tracing-bom from 1.2.4 to 1.2.5 #​3198
• Bump io.projectreactor:reactor-bom from 2023.0.4 to 2023.0.5 #​3197

v3.1.3

⭐ New Features

• fix bug at KafkaMessageListenerContainerTests.testInvokeRecordInterceptorAllSkipped() #​3094
• Align RecordInterceptor and BatchInterceptor lifecycle. #​3092
• ConcurrentMessageListenerContainer#isInExpectedState consistency problem #​3068
• Fix TestOOMError#testOOMCMLC throw ConcurrentModificationException #​3061

🐞 Bug Fixes

• Failing to handle deserialization exceptions in batch listener #​3118
• KafkaMessageListenerContainer doesn't properly clear threadState of AfterRollbackProcessor #​3102
• Listener exceptions not saved to the observation #​3085
• CommonDelegatingErrorHandler does not check delegates compatibility correctly #​3062
• DefaultErrorHandler is not able to seek in case of an exception during the commit #​3060

📔 Documentation

• Remove retry-topic-lcf.adoc introduce useLegacyFactoryConfigurer #​3087

🔨 Dependency Upgrades

• Bump org.springframework.data:spring-data-bom from 2023.1.3 to 2023.1.4 #​3139
• Bump org.springframework:spring-framework-bom from 6.1.4 to 6.1.5 #​3134
• Bump io.micrometer:micrometer-bom from 1.12.3 to 1.12.4 #​3132
• Bump kotlinVersion from 1.9.22 to 1.9.23 #​3131
• Bump io.micrometer:micrometer-tracing-bom from 1.2.3 to 1.2.4 #​3127
• Bump io.projectreactor:reactor-bom from 2023.0.3 to 2023.0.4 #​3125
• Bump org.apache.zookeeper:zookeeper from 3.8.3 to 3.8.4 #​3124

v3.1.2

Compare Source

⭐ New Features

• Provide a recovery callback for the execute method of RetryingDeserializer #​3036
• Provide a way to support Consumer#enforceRebalance #​3024
• minor improvement DelegatingInvocableHandler and AKLE relate #​2976
• GH-2974 Add NonNullApi and NonNullFields to package-info.java in 'annotation' package #​2974
• minor improvement error handler related #​2970
• GH-2967: Some minor improvements in RetryableTopicAnnotationProcessor #​2967
• improvements in MessagingMessageListenerAdapter and KafkaUtils #​2962

🐞 Bug Fixes

• False warning log for not committed offsets on CooperativeStickyAssignor strategy #​2991
• Can't recognize original exception when abortTransaction() failed #​2981
• spring doc website link needs updating #​2979
• DefaultErrorHandler#handleBatchAndReturnRemaining recovered invalid #​2968
• Spring Kafka Wait For Assignment Failed After Update To SpringBoot 3.2.0 #​2978

📔 Documentation

• Closing MockProducer options in reference docs #​2965

🔨 Dependency Upgrades

• Upgrade dependecies before release #​3027
• Bump io.micrometer:micrometer-bom from 1.12.1 to 1.12.2 #​2989
• Bump io.projectreactor:reactor-bom from 2023.0.1 to 2023.0.2 #​2988
• Bump org.springframework:spring-framework-bom from 6.1.2 to 6.1.3 #​2987
• Bump io.micrometer:micrometer-tracing-bom from 1.2.1 to 1.2.2 #​2986
• Bump org.springframework.data:spring-data-bom from 2023.1.1 to 2023.1.2 #​2985
• Bump kotlinVersion from 1.9.21 to 1.9.22 #​2973

❤️ Contributors

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

@​NathanQingyangXu, @​Wzy19930507, and @​jitokim

v3.1.1

⭐ New Features

• minor improvement to klabpp and knapar #​2947
• fix a default method defect in ConsumerFactory #​2945
• minor adjustment at MessagingMessageListenerAdapter #​2941
• minor improvement to DefaultKafkaHeaderMapper #​2940
• Fix typo at KafkaMessageListenerContainer and ContainerProperties #​2939
• reuse RecordHeader in AggregatingReplyingKafkaTemplate #​2932
• fix some defects of setting default Message headers in MessagingMessageListenerAdapter #​2908
• Free exceptions from ConsumerAwareRebalanceListener #​2887

🐞 Bug Fixes

• Fix KafkaTemplate.clusterId() for concurrency #​2943
• No parameter resolver for EmbeddedKafkaZKBroker #​2927
• Unable to send null payload with KafkaTemplate#send(Message) #​2924
• Annotation TopicPartition - partition attribute was not resolved from… #​2246

📔 Documentation

• Fix typo in javadoc #​2935
• RoutingKafkaTemplate configuration is throwing error after spring boot 3.1.2 #​2921
• EmbeddedKafkaKraftBroker.kafkaPorts(int... ports) is ignored #​2916

🔨 Dependency Upgrades

• Bump io.micrometer:micrometer-bom from 1.12.0 to 1.12.1 #​2960
• Bump org.springframework.data:spring-data-bom from 2023.1.0 to 2023.1.1 #​2959
• Bump org.junit:junit-bom from 5.10.0 to 5.10.1 #​2958
• Bump io.projectreactor:reactor-bom from 2023.0.0 to 2023.0.1 #​2957
• Bump log4jVersion from 2.21.0 to 2.21.1 #​2956
• Bump io.micrometer:micrometer-tracing-bom from 1.2.0 to 1.2.1 #​2955
• Bump kotlinVersion from 1.9.10 to 1.9.21 #​2953
• Bump org.springframework:spring-framework-bom from 6.1.0 to 6.1.2 #​2952
• Bump org.springframework.retry:spring-retry from 2.0.4 to 2.0.5 #​2951
• Bump kafkaVersion from 3.6.0 to 3.6.1 #​2950

❤️ Contributors

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

@​NathanQingyangXu, @​Wzy19930507, @​dependabot[bot], @​dogglezz, @​michaldo, and @​s7474

v3.1.0

⭐ New Features

• remove unnecessary property setting statement in EmbeddedKafkaKraftBroker #​2893
• GH-2654: Incorrect retry topic suffix #​2876
• The TRUSTED_PACKAGES field in the DefaultJackson2JavaTypeMapper has also been improved to have an ImmutableList type. #​2875
• No early bean initialization from EmbeddedKafkaContextCustomizer #​2870
• GH-2862: Add Option to Log Recovery to DLPR #​2869
• Support Validator in ErrorHandlingDeserializer #​2861
• GH-2731: fix count and time ack mode #​2858
• If cluster id is null and observation is enabled, KafkaTemplate tries to retrieve it on each produce #​2853
• Provide a way to define a ContainerCustomizer per KafkaListener #​2825

🐞 Bug Fixes

• Fix TX Check in RoutingKafkaTemplate #​2899
• Fix Issues in DefaultKafkaProducerFactory#updateConfigs() #​2897
• Under-documented "Manually Assigning All Partitions" #​2891
• add a missing left quote in AbstractKafkaListenerEndpoint#getEndpointDescription() #​2882
• fix CONSUMER_RECORDS_CLASS_NAME constant error in KafkaAvroBeanRegistrationAotProcessor.java #​2881
• ProducerInterceptor in KafkaTempalte unvaild #​2874
• Admin is boot up by turning on observability #​2859

📔 Documentation

• Improve Documentation about Acknowledgment.nack() #​2906
• Improve Documentation: State on OOO-Commits page that AsyncAcks cannot be combined with nack() #​2905
• remove 'dead links' in javadocs #​2896
• Update testing.adoc > "@EmbeddedKafka Annotation with JUnit5" section #​2894
• fix some typos #​2885
• update reference documentation gradle task in README.md #​2880
• cosmetic doc improvements part 4 #​2879
• cosmetic doc improvements part 3 #​2877
• some cosmetic improvements of the reference - part 2 #​2873
• Streams Doc Polishing #​2871
• Reference Doc Improvements #​2867

🔨 Dependency Upgrades

• Upgrade Dependency Versions #​2911
• CVE-2023-44981 for zookeeper version #​2898

🔨 Tasks

• Eliminate the Use of StringBuffer #​2909

❤️ Contributors

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

@​Alchemik, @​NathanQingyangXu, @​Wzy19930507, @​ch4570, @​pat-goins, and @​powibol

External Links

• Reference Documentation

v3.0.16

🐞 Bug Fixes

• Duplicate record consumption due to offset decrease in last offset commit #​3191
• Setting the Kafka Streams property default.dsl.store has no effect #​3182
• BatchInterceptor is not working properly with retries #​3171
• MDCs are missing in logs produced by DefaultErrorHandler. #​3153
• In kafka events, the traceId and spanId are not written in the logs #​3150

🔨 Dependency Upgrades

• Bump org.springframework:spring-framework-bom from 6.0.18 to 6.0.19 #​3196
• Bump io.projectreactor:reactor-bom from 2022.0.17 to 2022.0.18 #​3195

v3.0.15

⭐ New Features

• Provide a way to support Consumer#enforceRebalance #​3075

🐞 Bug Fixes

• Failing to handle deserialization exceptions in batch listener #​3119
• KafkaMessageListenerContainer doesn't properly clear threadState of AfterRollbackProcessor #​3103
• Listener exceptions not saved to the observation #​3086

🔨 Dependency Upgrades

• Bump kotlinVersion from 1.7.20 to 1.7.22 #​3133
• Bump org.springframework:spring-framework-bom from 6.0.17 to 6.0.18 #​3128
• Bump io.projectreactor:reactor-bom from 2022.0.16 to 2022.0.17 #​3126

v3.0.14

🐞 Bug Fixes

• False warning log for not committed offsets on CooperativeStickyAssignor strategy #​2995
• Can't recognize original exception when abortTransaction() failed #​2993
• Fix KafkaTemplate.clusterId() for concurrency #​2946
• Annotation TopicPartition - partition attribute was not resolved from… #​2938
• Unable to send null payload with KafkaTemplate#send(Message) #​2928

🔨 Dependency Upgrades

• Upgrade dependecies before release #​3026

v3.0.13

⭐ New Features

• If cluster id is null and observation is enabled, KafkaTemplate tries to retrieve it on each produce #​2856

🐞 Bug Fixes

• Under-documented "Manually Assigning All Partitions" #​2901
• The result of ProducerInterceptor.onSend() is out of use #​2884
• Fix CONSUMER_RECORDS_CLASS_NAME constant error in KafkaAvroBeanRegistrationAotProcessor #​2883

🔨 Dependency Upgrades

• Upgrade Dependency Versions #​2910
• Upgrade Spring Retry Version #​2848

🔨 Tasks

• Add kafka-server-common Transitive Test Dependency #​2849

❤️ Contributors

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

@​Wzy19930507

External Links

• Reference Documentation

v3.0.12

🐞 Bug Fixes

• Remove Arrays.toString() from JsonDeserializer #​2839
• KafkaAdmin NPE With Typo in Config Name #​2834
• CommonDelegatingErrorHandler: Missing updateClassifier() in addDelegate() #​2830
• KafkaTemplate is reporting 2 errors to observation #​2824

🔨 Dependency Upgrades

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

🔨 Tasks

• Deprecate DestinationTopicPropertiesFactory CTORs #​2793
• Remove outdated comments in ListenerContainerFactoryConfigurer #​2776

❤️ Contributors

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

@​WhiteDG

External Links

• Reference Documentation

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

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

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

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

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

v3.0.5

🐞 Bug Fixes

• Deadlock on lifecycleMonitor #​2627
• Allow the Spring Cloud Stream Binder to Inject a KafkaAdmin for Observability #​2626
• Reclassify Exception in FallbackBatchErrorHandler When Exception Changes #​2620
• Spring Kafka Listener uses stale oauthbearer token, fails to connect after initial token expired. #​2612

🔨 Dependency Upgrades

• Upgrade Micrometer, Reactor, Spring Versions #​2634

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

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

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

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

---

Configuration

📅 Schedule: Branch creation - At any time (no schedule defined), 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.

🔕 Ignore: Close this PR and you won't be reminded about this update again.

---

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

---

This PR has been generated by Mend Renovate. View repository job log here.

[renovate]

Renovate Ignore Notification

Because you closed this PR without merging, Renovate will ignore this update. You will not get PRs for any future 3.x releases. But if you manually upgrade to 3.x then Renovate will re-enable minor and patch updates automatically.

If you accidentally closed this PR, or if you changed your mind: rename this PR to get a fresh replacement PR.