diff --git a/ccx_messaging/publishers/kafka_publisher.py b/ccx_messaging/publishers/kafka_publisher.py index bf02b5f..e2c9aab 100644 --- 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 index 5837b10..a662e2a 100644 --- 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