From 2a8833d7a9cf7c1c7cb024ebb66af88414959546 Mon Sep 17 00:00:00 2001
From: admin <fakc445@gmail.com>
Date: Wed, 9 Apr 2025 15:47:44 +0300
Subject: [PATCH] feat: fix

---
 main.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/main.py b/main.py
index 34239fb..4fa0cd7 100644
--- a/main.py
+++ b/main.py
@@ -10,6 +10,7 @@ from starlette.staticfiles import StaticFiles
 import routers
 from constants import API_ROOT
 from external.kafka import producer, consume_messages
+from external.kafka.producer import init_producer
 
 origins = [
     'http://localhost:5173'
@@ -19,6 +20,7 @@ origins = [
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     try:
+        await init_producer()
         await producer.start()
     except KafkaConnectionError as e:
         print(e)