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

---
 external/kafka/consumer.py | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/external/kafka/consumer.py b/external/kafka/consumer.py
index 9b0f705..f0ebff9 100644
--- a/external/kafka/consumer.py
+++ b/external/kafka/consumer.py
@@ -6,15 +6,15 @@ from backend.session import session_maker
 from external.kafka.context import context
 from external.kafka.services.consumer_service import ConsumerService
 
-consumer = AIOKafkaConsumer(
-    KAFKA_CONSUMER_TOPIC,
-    bootstrap_servers=KAFKA_URL,
-    security_protocol='SSL',
-    ssl_context=context,
-)
 
 
 async def consume_messages():
+    consumer = AIOKafkaConsumer(
+        KAFKA_CONSUMER_TOPIC,
+        bootstrap_servers=KAFKA_URL,
+        security_protocol='SSL',
+        ssl_context=context,
+    )
     try:
         await consumer.start()
     except KafkaConnectionError as e: