Fix Kafka clowder configuration (#216)

RedHatInsights · May 8, 2024 · ce6a224 · ce6a224
1 parent 4f6ecfe
commit ce6a224
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/ccx_messaging/utils/clowder.py b/ccx_messaging/utils/clowder.py
@@ -80,9 +80,7 @@ def _add_kafka_config(config):
     print("Kafka configuration updated from Clowder configuration")
 
     if configure_consumer:
-        config["service"]["consumer"]["kwargs"]["bootstrap.servers"] = kafka_broker_config[
-            "bootstrap.servers"
-        ]
+        config["service"]["consumer"]["kwargs"]["kafka_broker_config"] = kafka_broker_config
         consumer_topic = config["service"]["consumer"]["kwargs"].get("incoming_topic")
         dlq_topic = config["service"]["consumer"]["kwargs"].get("dead_letter_queue_topic")
         if consumer_topic in app_common_python.KafkaTopics:
@@ -96,9 +94,7 @@ def _add_kafka_config(config):
             config["service"]["consumer"]["kwargs"]["dead_letter_queue_topic"] = topic_cfg.name
 
     if configure_publisher:
-        config["service"]["publisher"]["kwargs"]["bootstrap.servers"] = kafka_broker_config[
-            "bootstrap.servers"
-        ]
+        config["service"]["publisher"]["kwargs"]["kafka_broker_config"] = kafka_broker_config
         producer_topic = config["service"]["publisher"]["kwargs"].get("outgoing_topic")
         if producer_topic in app_common_python.KafkaTopics:
             topic_cfg = app_common_python.KafkaTopics[producer_topic]