From d88e0bda8f67e8ab2fcd2894d92c8f1843f1a97e Mon Sep 17 00:00:00 2001 From: Foivos Zakkak Date: Mon, 19 Feb 2024 12:06:02 +0200 Subject: [PATCH] Make registration of OAuthBearerValidatorCallbackHandler conditional `org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler` depends on the optional `org.jose4j.keys.resolvers.VerificationKeyResolver` so it should only be registered when the latter is present, similarly to `org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler` Closes https://github.com/quarkusio/quarkus/issues/38851 --- .../io/quarkus/kafka/client/deployment/KafkaProcessor.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/extensions/kafka-client/deployment/src/main/java/io/quarkus/kafka/client/deployment/KafkaProcessor.java b/extensions/kafka-client/deployment/src/main/java/io/quarkus/kafka/client/deployment/KafkaProcessor.java index 3a574b4424f85..18549b1f92eb4 100644 --- a/extensions/kafka-client/deployment/src/main/java/io/quarkus/kafka/client/deployment/KafkaProcessor.java +++ b/extensions/kafka-client/deployment/src/main/java/io/quarkus/kafka/client/deployment/KafkaProcessor.java @@ -415,6 +415,9 @@ public void withSasl(CombinedIndexBuildItem index, reflectiveClassCondition.produce(new ReflectiveClassConditionBuildItem( "org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler", "org.jose4j.keys.resolvers.VerificationKeyResolver")); + reflectiveClassCondition.produce(new ReflectiveClassConditionBuildItem( + "org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler", + "org.jose4j.keys.resolvers.VerificationKeyResolver")); } private void registerJDKLoginModules(BuildProducer reflectiveClass) {