diff --git a/kafka-admin/pom.xml b/kafka-admin/pom.xml index a94c1873..677c44f1 100644 --- a/kafka-admin/pom.xml +++ b/kafka-admin/pom.xml @@ -223,6 +223,10 @@ io.quarkus quarkus-hibernate-validator + + io.quarkus + quarkus-kafka-client + io.smallrye.common smallrye-common-annotation diff --git a/kafka-admin/src/main/java/org/bf2/admin/kafka/admin/handlers/OperationsHandler.java b/kafka-admin/src/main/java/org/bf2/admin/kafka/admin/handlers/OperationsHandler.java index 773606e7..16b52009 100644 --- a/kafka-admin/src/main/java/org/bf2/admin/kafka/admin/handlers/OperationsHandler.java +++ b/kafka-admin/src/main/java/org/bf2/admin/kafka/admin/handlers/OperationsHandler.java @@ -1,5 +1,6 @@ package org.bf2.admin.kafka.admin.handlers; +import io.quarkus.runtime.annotations.RegisterForReflection; import org.bf2.admin.kafka.admin.Operations; import org.bf2.admin.kafka.admin.model.Types; import org.eclipse.microprofile.openapi.annotations.Operation; @@ -29,6 +30,7 @@ import java.util.Optional; import java.util.concurrent.CompletionStage; +@RegisterForReflection public interface OperationsHandler { @POST diff --git a/kafka-admin/src/main/resources/application.properties b/kafka-admin/src/main/resources/application.properties index ea667b48..e6c403ff 100644 --- a/kafka-admin/src/main/resources/application.properties +++ b/kafka-admin/src/main/resources/application.properties @@ -21,11 +21,9 @@ quarkus.http.ssl.certificate.key-file=${kafka.admin.tls.key:} # See https://quarkus.io/guides/kafka-dev-services # Enable when using quarkus-kafka-client -#quarkus.kafka.devservices.enabled=false +quarkus.kafka.devservices.enabled=false -# Remove when quarkus-kafka-client supports Kafka client 3.0 -quarkus.index-dependency.kafka-clients.group-id=org.apache.kafka -quarkus.index-dependency.kafka-clients.artifact-id=kafka-clients +quarkus.vertx.max-event-loop-execute-time=4000 # The following properties will be used when adding JWT RBAC provided by quarkus-smallrye-jwt quarkus.smallrye-jwt.enabled=true @@ -45,7 +43,7 @@ quarkus.swagger-ui.theme=monokai quarkus.log.category."org.apache.kafka".level=WARN -kafka.admin.oauth.enabled=${quarkus.smallrye-jwt.enabled} +kafka.admin.oauth.enabled=${quarkus.smallrye-jwt.enabled:true} # Default limit to the number of partitions that new topics may have configured. kafka.admin.num.partitions.max=100 # Default resource/operations mapping diff --git a/pom.xml b/pom.xml index 21551ec0..98ee0a70 100644 --- a/pom.xml +++ b/pom.xml @@ -28,7 +28,6 @@ 2.7.6.Final 1.2.1 - 3.0.0 0.8.1 3.5.3 2.1 @@ -70,11 +69,6 @@ kafka-admin ${project.version} - - org.apache.kafka - kafka-clients - ${kafka.version} - io.strimzi kafka-oauth-client