Merge pull request #34077 from quarkusio/dependabot/maven/kafka3.vers…

…ion-3.5.0 Bump kafka3.version from 3.4.0 to 3.5.0
quarkusio · Jul 3, 2023 · ec12e13 · ec12e13
2 parents 055e06d + b77b6ec
commit ec12e13
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/bom/application/pom.xml b/bom/application/pom.xml
@@ -149,7 +149,7 @@
         <reactive-streams.version>1.0.4</reactive-streams.version>
         <jboss-logging.version>3.5.1.Final</jboss-logging.version>
         <mutiny.version>2.3.1</mutiny.version>
-        <kafka3.version>3.4.0</kafka3.version>
+        <kafka3.version>3.5.0</kafka3.version>
         <lz4.version>1.8.0</lz4.version> <!-- dependency of the kafka-clients that could be overridden by other imported BOMs in the platform -->
         <snappy.version>1.1.10.1</snappy.version>
         <strimzi-test-container.version>0.100.0</strimzi-test-container.version>

diff --git a/...s/deployment/src/main/java/io/quarkus/kafka/streams/deployment/KafkaStreamsProcessor.java b/...s/deployment/src/main/java/io/quarkus/kafka/streams/deployment/KafkaStreamsProcessor.java
@@ -12,6 +12,7 @@
 import org.apache.kafka.streams.errors.DefaultProductionExceptionHandler;
 import org.apache.kafka.streams.errors.LogAndFailExceptionHandler;
 import org.apache.kafka.streams.processor.FailOnInvalidTimestamp;
+import org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier;
 import org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor;
 import org.rocksdb.RocksDBException;
 import org.rocksdb.Status;
@@ -75,6 +76,8 @@ private void registerCompulsoryClasses(BuildProducer<ReflectiveClassBuildItem> r
                     ReflectiveClassBuildItem.builder(DEFAULT_PARTITION_GROUPER)
                             .build());
         }
+        reflectiveClasses.produce(ReflectiveClassBuildItem.builder(DefaultKafkaClientSupplier.class)
+                .build());
         reflectiveClasses.produce(ReflectiveClassBuildItem.builder(DefaultProductionExceptionHandler.class)
                 .build());
         reflectiveClasses.produce(ReflectiveClassBuildItem.builder(FailOnInvalidTimestamp.class)