Update producer config

lsst-dm · Aug 28, 2024 · 18fa9ec · 18fa9ec
1 parent 914996f
commit 18fa9ec
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main.py b/src/main.py
@@ -96,6 +96,7 @@ def detector_load(conf: dict, instrument: str) -> list[int]:
     return active_detectors
 
 async def fan_out_msg(
+    producer,
     fan_out_topic,
     data
 ):
@@ -219,9 +220,7 @@ async def main() -> None:
 
     # https://aiokafka.readthedocs.io/en/stable/producer.html
     producer = AIOKafkaProducer(
-        fan_out_topic,
-        bootstrap_servers=prompt_processing_kafka_cluster,
-        enable_idempotence=True
+        bootstrap_servers=prompt_processing_kafka_cluster
     )
     await producer.start()