From 2730ced37ec5511b45efab2addb695b829042a37 Mon Sep 17 00:00:00 2001
From: admin <fakc445@gmail.com>
Date: Wed, 9 Apr 2025 15:50:45 +0300
Subject: [PATCH] feat: fix

---
 external/kafka/producer.py | 2 +-
 main.py                    | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/external/kafka/producer.py b/external/kafka/producer.py
index 898bc8e..ab4e152 100644
--- a/external/kafka/producer.py
+++ b/external/kafka/producer.py
@@ -14,4 +14,4 @@ async def init_producer():
         bootstrap_servers=KAFKA_URL,
         security_protocol='SSL',
         ssl_context=context,
-    )
+    )
\ No newline at end of file
diff --git a/main.py b/main.py
index 4fa0cd7..e038f6b 100644
--- a/main.py
+++ b/main.py
@@ -21,7 +21,8 @@ origins = [
 async def lifespan(app: FastAPI):
     try:
         await init_producer()
-        await producer.start()
+        if producer:
+            await producer.start()
     except KafkaConnectionError as e:
         print(e)