[camel-quarkus] branch main updated: Fix #3284 to get kafka.bootstrap.servers from DevServicesLauncherConfigResultBuildItem (#3287)

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new 22ad418  Fix #3284 to get kafka.bootstrap.servers from DevServicesLauncherConfigResultBuildItem (#3287)
22ad418 is described below

commit 22ad4182ca3f53e730a600f42f4b5d6192bcd3ca
Author: Amos Feng <zh...@gmail.com>
AuthorDate: Thu Nov 11 17:26:29 2021 +0800

    Fix #3284 to get kafka.bootstrap.servers from DevServicesLauncherConfigResultBuildItem (#3287)
---
 .../camel/quarkus/component/kafka/deployment/KafkaProcessor.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/extensions/kafka/deployment/src/main/java/org/apache/camel/quarkus/component/kafka/deployment/KafkaProcessor.java b/extensions/kafka/deployment/src/main/java/org/apache/camel/quarkus/component/kafka/deployment/KafkaProcessor.java
index 9acafda..3f573ff 100644
--- a/extensions/kafka/deployment/src/main/java/org/apache/camel/quarkus/component/kafka/deployment/KafkaProcessor.java
+++ b/extensions/kafka/deployment/src/main/java/org/apache/camel/quarkus/component/kafka/deployment/KafkaProcessor.java
@@ -24,10 +24,10 @@ import io.quarkus.deployment.Capability;
 import io.quarkus.deployment.IsNormal;
 import io.quarkus.deployment.annotations.BuildProducer;
 import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.builditem.DevServicesLauncherConfigResultBuildItem;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
 import io.quarkus.deployment.builditem.RunTimeConfigurationDefaultBuildItem;
 import io.quarkus.deployment.dev.devservices.GlobalDevServicesConfig;
-import io.quarkus.kafka.client.deployment.DevServicesKafkaBrokerBuildItem;
 import io.quarkus.kafka.client.deployment.KafkaBuildTimeConfig;
 import org.apache.camel.quarkus.component.kafka.KafkaClientFactoryProducer;
 import org.eclipse.microprofile.config.Config;
@@ -36,6 +36,7 @@ import org.eclipse.microprofile.config.ConfigProvider;
 class KafkaProcessor {
     private static final String FEATURE = "camel-kafka";
     private static final String CAMEL_KAFKA_BROKERS = "camel.component.kafka.brokers";
+    private static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers";
 
     @BuildStep
     FeatureBuildItem feature() {
@@ -53,7 +54,7 @@ class KafkaProcessor {
 
     @BuildStep(onlyIfNot = IsNormal.class, onlyIf = GlobalDevServicesConfig.Enabled.class)
     public void configureKafkaComponentForDevServices(
-            DevServicesKafkaBrokerBuildItem kafkaBrokerBuildItem,
+            DevServicesLauncherConfigResultBuildItem devServiceResult,
             KafkaBuildTimeConfig kafkaBuildTimeConfig,
             BuildProducer<RunTimeConfigurationDefaultBuildItem> runTimeConfig) {
 
@@ -62,7 +63,7 @@ class KafkaProcessor {
 
         if (brokers.isEmpty() && kafkaBuildTimeConfig.devservices.enabled.orElse(true)) {
             runTimeConfig.produce(new RunTimeConfigurationDefaultBuildItem(CAMEL_KAFKA_BROKERS,
-                    kafkaBrokerBuildItem.getBootstrapServers()));
+                    devServiceResult.getConfig().get(KAFKA_BOOTSTRAP_SERVERS)));
         }
     }
 }