From f083c19cdc784579b3f5e3f5abbdf4e2d411bc03 Mon Sep 17 00:00:00 2001
From: AlexSserb <aserbin190@gmail.com>
Date: Wed, 9 Apr 2025 18:59:00 +0400
Subject: [PATCH] fix: kafka consumer group id for workers

---
 external/kafka/consumer.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/external/kafka/consumer.py b/external/kafka/consumer.py
index f0ebff9..84f3ff0 100644
--- a/external/kafka/consumer.py
+++ b/external/kafka/consumer.py
@@ -12,6 +12,7 @@ async def consume_messages():
     consumer = AIOKafkaConsumer(
         KAFKA_CONSUMER_TOPIC,
         bootstrap_servers=KAFKA_URL,
+        group_id='crm',
         security_protocol='SSL',
         ssl_context=context,
     )