moved producer location and added logging.

lsst-dm · Sep 30, 2024 · aa70512 · aa70512
1 parent 1a519bb
commit aa70512
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/src/main.py b/src/main.py
@@ -158,13 +158,7 @@ async def main() -> None:
         sasl_mechanism=sasl_mechanism,
         sasl_plain_username=sasl_username,
         sasl_plain_password=sasl_password,
-    )
-
-    # https://aiokafka.readthedocs.io/en/stable/producer.html
-    producer = AIOKafkaProducer(
-        bootstrap_servers=prompt_processing_kafka_cluster
-    )
-    await producer.start()
+    ) 
 
     latiss_gauge = Gauge(
         "latiss_next_visit_messages", "next visit nessages with latiss as instrument"
@@ -212,6 +206,13 @@ async def main() -> None:
 
     tasks = set()
 
+    # https://aiokafka.readthedocs.io/en/stable/producer.html
+    producer = AIOKafkaProducer(
+        bootstrap_servers=prompt_processing_kafka_cluster
+    )
+    await producer.start()
+    logging.info ("started kafka producer")
+
     async with httpx.AsyncClient() as client:
 
         try: