You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2021/11/24 13:47:43 UTC
[camel-quarkus] branch main updated: Verify that kafka.bootstrap.servers property is available before attempting to use it for dev services
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton 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 4a9a561 Verify that kafka.bootstrap.servers property is available before attempting to use it for dev services
4a9a561 is described below
commit 4a9a5612ae55d8d8bc61e5b1140ee3d63ad3d03d
Author: James Netherton <ja...@gmail.com>
AuthorDate: Wed Nov 24 11:36:18 2021 +0000
Verify that kafka.bootstrap.servers property is available before attempting to use it for dev services
Fixes #3329
---
.../camel/quarkus/component/kafka/deployment/KafkaProcessor.java | 6 ++++--
1 file changed, 4 insertions(+), 2 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 3f573ff..90e2945 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
@@ -62,8 +62,10 @@ class KafkaProcessor {
Optional<String> brokers = config.getOptionalValue(CAMEL_KAFKA_BROKERS, String.class);
if (brokers.isEmpty() && kafkaBuildTimeConfig.devservices.enabled.orElse(true)) {
- runTimeConfig.produce(new RunTimeConfigurationDefaultBuildItem(CAMEL_KAFKA_BROKERS,
- devServiceResult.getConfig().get(KAFKA_BOOTSTRAP_SERVERS)));
+ String kafkaBootstrapServers = devServiceResult.getConfig().get(KAFKA_BOOTSTRAP_SERVERS);
+ if (kafkaBootstrapServers != null) {
+ runTimeConfig.produce(new RunTimeConfigurationDefaultBuildItem(CAMEL_KAFKA_BROKERS, kafkaBootstrapServers));
+ }
}
}
}