Fail to start when service binding is enabled and Kafka boostrap serv…

…ers not set Fixes: #16682
quarkusio · Jun 22, 2021 · 274dfdf · 274dfdf
1 parent 65e3aa0
commit 274dfdf
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 0 deletions.
diff --git a/...ka-client/deployment/src/main/java/io/quarkus/kafka/client/deployment/KafkaProcessor.java b/...ka-client/deployment/src/main/java/io/quarkus/kafka/client/deployment/KafkaProcessor.java
@@ -53,15 +53,18 @@
 import io.quarkus.deployment.Capabilities;
 import io.quarkus.deployment.Capability;
 import io.quarkus.deployment.Feature;
+import io.quarkus.deployment.IsNormal;
 import io.quarkus.deployment.annotations.BuildProducer;
 import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.annotations.Consume;
 import io.quarkus.deployment.annotations.ExecutionTime;
 import io.quarkus.deployment.annotations.Record;
 import io.quarkus.deployment.builditem.AdditionalIndexedClassesBuildItem;
 import io.quarkus.deployment.builditem.CombinedIndexBuildItem;
 import io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
 import io.quarkus.deployment.builditem.IndexDependencyBuildItem;
+import io.quarkus.deployment.builditem.RuntimeConfigSetupCompleteBuildItem;
 import io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem;
 import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem;
 import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
@@ -230,6 +233,15 @@ void loadSnappyIfEnabled(KafkaRecorder recorder, KafkaBuildTimeConfig config) {
         }
     }
 
+    @Consume(RuntimeConfigSetupCompleteBuildItem.class)
+    @BuildStep(onlyIf = IsNormal.class)
+    @Record(ExecutionTime.RUNTIME_INIT)
+    void checkBoostrapServers(KafkaRecorder recorder, Capabilities capabilities) {
+        if (capabilities.isPresent(Capability.KUBERNETES_SERVICE_BINDING)) {
+            recorder.checkBoostrapServers();
+        }
+    }
+
     private void handleOpenTracing(BuildProducer<ReflectiveClassBuildItem> reflectiveClass, Capabilities capabilities) {
         //opentracing contrib kafka interceptors: https://github.com/opentracing-contrib/java-kafka-client
         if (capabilities.isPresent(Capability.OPENTRACING)) {

diff --git a/...ons/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaRecorder.java b/...ons/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaRecorder.java
@@ -6,7 +6,10 @@
 import java.io.IOException;
 import java.io.UncheckedIOException;
 import java.net.URL;
+import java.util.Optional;
 
+import org.eclipse.microprofile.config.Config;
+import org.eclipse.microprofile.config.ConfigProvider;
 import org.xerial.snappy.OSInfo;
 import org.xerial.snappy.SnappyError;
 import org.xerial.snappy.SnappyErrorCode;
@@ -71,4 +74,16 @@ private static File extractLibraryFile(URL library, String name) {
         return extractedLibFile;
     }
 
+    public void checkBoostrapServers() {
+        Config config = ConfigProvider.getConfig();
+        Boolean serviceBindingEnabled = config.getValue("quarkus.kubernetes-service-binding.enabled", Boolean.class);
+        if (!serviceBindingEnabled) {
+            return;
+        }
+        Optional<String> boostrapServersOptional = config.getOptionalValue("kafka.bootstrap.servers", String.class);
+        if (boostrapServersOptional.isEmpty()) {
+            throw new IllegalStateException(
+                    "The property 'kafka.bootstrap.servers' must be set when 'quarkus.kubernetes-service-binding.enabled' has been set to 'true'");
+        }
+    }
 }