From ba2a95f22e626efd63dd7db927ae453b08a3dde5 Mon Sep 17 00:00:00 2001 From: admin Date: Wed, 9 Apr 2025 15:47:21 +0300 Subject: [PATCH] feat: fix --- external/kafka/producer.py | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/external/kafka/producer.py b/external/kafka/producer.py index 6f56cdb..898bc8e 100644 --- a/external/kafka/producer.py +++ b/external/kafka/producer.py @@ -1,10 +1,17 @@ +from typing import Optional + from aiokafka import AIOKafkaProducer from backend.config import KAFKA_URL from external.kafka.context import context -producer = AIOKafkaProducer( - bootstrap_servers=KAFKA_URL, - security_protocol='SSL', - ssl_context=context, -) +producer: Optional[AIOKafkaProducer] = None + + +async def init_producer(): + global producer + producer = AIOKafkaProducer( + bootstrap_servers=KAFKA_URL, + security_protocol='SSL', + ssl_context=context, + )