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