Use all the Kafka bootstrap servers provided by Clowder

RedHatInsights · Dec 4, 2023 · 41c9124 · 41c9124
1 parent 039c0be
commit 41c9124
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/ccx_messaging/publishers/kafka_publisher.py b/ccx_messaging/publishers/kafka_publisher.py
@@ -84,7 +84,7 @@ def publish(self, input_msg: dict, report: str):
         raise NotImplementedError()
 
     def error(self, input_msg: dict, ex: Exception):
-        """Handle pipeline errores by logging them."""
+        """Handle pipeline errors by logging them."""
         # The super call is probably unnecessary because the default behavior
         # is to do nothing, but let's call it in case it ever does anything.
         super().error(input_msg, ex)

diff --git a/ccx_messaging/utils/clowder.py b/ccx_messaging/utils/clowder.py
@@ -37,10 +37,10 @@ def apply_clowder_config(manifest):
             break
 
     clowder_broker_config = app_common_python.LoadedConfig.kafka.brokers[0]
-    kafka_url = f"{clowder_broker_config.hostname}:{clowder_broker_config.port}"
-    logger.debug("Kafka URL: %s", kafka_url)
+    kafka_urls = app_common_python.KafkaServers
+    logger.debug("Kafka URLs: %s", kafka_urls)
 
-    kafka_broker_config = {"bootstrap.servers": kafka_url}
+    kafka_broker_config = {"bootstrap.servers": kafka_urls}
 
     if clowder_broker_config.cacert:
         # Current Kafka library is not able to handle the CA file, only a path to it