fix error in passing conf

lsst-dm · Oct 30, 2024 · ad814dd · ad814dd
1 parent 2db2b0e
commit ad814dd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/activator/activator.py b/python/activator/activator.py
@@ -263,7 +263,7 @@ def keda_start():
         'enable.auto.commit': False
     }
 
-    fan_out_consumer = kafka.Consumer(conf=fan_out_consumer_conf, logger=_log)
+    fan_out_consumer = kafka.Consumer(fan_out_consumer_conf, logger=_log)
 
     _log.info("starting fan out consumer")