(camel) branch main updated: CAMEL-21429: camel-kafka: Upgrade to Kafka 3.9.1 (#18333)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new f3a75c17191 CAMEL-21429: camel-kafka: Upgrade to Kafka 3.9.1 (#18333)
f3a75c17191 is described below

commit f3a75c17191bf3c31c4fa2fafbe04a0b4683acdb
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Jun 10 15:10:21 2025 +0200

    CAMEL-21429: camel-kafka: Upgrade to Kafka 3.9.1 (#18333)
---
 .../camel/component/kafka/integration/KafkaConsumerStopIT.java      | 6 +++---
 parent/pom.xml                                                      | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerStopIT.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerStopIT.java
index 987f64ecccb..64ff99a0728 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerStopIT.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerStopIT.java
@@ -27,7 +27,7 @@ import org.apache.camel.component.kafka.KafkaFetchRecords;
 import org.apache.camel.component.kafka.MockConsumerInterceptor;
 import org.apache.camel.component.kafka.integration.common.KafkaTestUtil;
 import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer;
+import org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
@@ -122,8 +122,8 @@ public class KafkaConsumerStopIT extends 
BaseKafkaTestSupport {
             throws Exception {
         Try<Object> delegate = 
ReflectionUtils.tryToReadFieldValue(org.apache.kafka.clients.consumer.KafkaConsumer.class,
                 "delegate", kafkaClientConsumer);
-        LegacyKafkaConsumer cd = (LegacyKafkaConsumer) delegate.get();
-        Try<Object> closedTry = 
ReflectionUtils.tryToReadFieldValue(LegacyKafkaConsumer.class,
+        ClassicKafkaConsumer cd = (ClassicKafkaConsumer) delegate.get();
+        Try<Object> closedTry = 
ReflectionUtils.tryToReadFieldValue(ClassicKafkaConsumer.class,
                 "closed", cd);
         return (boolean) closedTry.get();
     }
diff --git a/parent/pom.xml b/parent/pom.xml
index 7e3e62881c7..e59200615e3 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -326,7 +326,7 @@
         <jxmpp-version>1.1.0</jxmpp-version>
         <jython-version>2.7.4</jython-version>
         <jzlib-version>1.1.3</jzlib-version>
-        <kafka-version>3.8.1</kafka-version>
+        <kafka-version>3.9.1</kafka-version>
         <keycloak-client-version>26.0.5</keycloak-client-version>
         <kubernetes-client-version>7.3.1</kubernetes-client-version>
         <kudu-version>1.17.1</kudu-version>