WIP - Pass Quarkus Kafka dev services broker URL to Camel

extensions/kafka/runtime/pom.xml

@@ -47,6 +47,11 @@
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-kafka</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-junit5</artifactId>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 
     <build>

extensions/kafka/runtime/src/main/java/org/apache/camel/quarkus/component/kafka/test/CamelQuarkusNativeImageLauncher.java

@@ -0,0 +1,26 @@
+package org.apache.camel.quarkus.component.kafka.test;
+
+import java.util.Collections;
+import java.util.Optional;
+
+import io.quarkus.test.common.ArtifactLauncher.InitContext.DevServicesLaunchResult;
+import io.quarkus.test.common.DefaultNativeImageLauncher;
+import org.eclipse.microprofile.config.Config;
+import org.eclipse.microprofile.config.ConfigProvider;
+
+public class CamelQuarkusNativeImageLauncher extends DefaultNativeImageLauncher {
+
+    @Override
+    public void init(NativeImageInitContext initContext) {
+        super.init(initContext);
+
+        Config config = ConfigProvider.getConfig();
+        DevServicesLaunchResult result = initContext.getDevServicesLaunchResult();
+
+        String kafkaBootstrapServers = result.properties().get("kafka.bootstrap.servers");
+        Optional<String> camelKafkaBrokers = config.getOptionalValue("camel.component.kafka.brokers", String.class);
+        if (kafkaBootstrapServers != null && camelKafkaBrokers.isEmpty()) {
+            includeAsSysProps(Collections.singletonMap("camel.component.kafka.brokers", kafkaBootstrapServers));
+        }
+    }
+}

extensions/kafka/runtime/src/main/resources/META-INF/services/io.quarkus.test.common.NativeImageLauncher

@@ -0,0 +1 @@
+org.apache.camel.quarkus.component.kafka.test.CamelQuarkusNativeImageLauncher