From 18fa9ec88749b0f020bf315135eee854baf085e5 Mon Sep 17 00:00:00 2001 From: dspeck1 Date: Wed, 28 Aug 2024 15:35:36 -0500 Subject: [PATCH] Update producer config --- src/main.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main.py b/src/main.py index 52faf05..7b7373b 100644 --- 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()