fix: kafka consumer group id for workers

2025-04-09 18:59:00 +04:00
parent e6674bd576
commit f083c19cdc
1 changed files with 1 additions and 0 deletions
--- 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,
    )