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,
+    )