Merge pull request #127 from juandspy/fix-support-for-multi-kafka

[CCXDEV-12238] Fix bug with the kafka urls
RedHatInsights · Dec 7, 2023 · 6dc3be5 · 6dc3be5
2 parents 1b0d813 + 749bfde
commit 6dc3be5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ccx_messaging/utils/clowder.py b/ccx_messaging/utils/clowder.py
@@ -40,7 +40,7 @@ def apply_clowder_config(manifest):
     kafka_urls = app_common_python.KafkaServers
     logger.debug("Kafka URLs: %s", kafka_urls)
 
-    kafka_broker_config = {"bootstrap.servers": kafka_urls}
+    kafka_broker_config = {"bootstrap.servers": ",".join(kafka_urls)}
 
     if clowder_broker_config.cacert:
         # Current Kafka library is not able to handle the CA file, only a path to it