Merge pull request #312 from cardanoapi/fix/api-status-page-kafka

fix: fix consumer-group name for kafka health check
cardanoapi · Jan 17, 2025 · 2f7055f · 2f7055f
2 parents ad79e27 + a333566
commit 2f7055f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/api/backend/app/services/kafka_service.py b/api/backend/app/services/kafka_service.py
@@ -21,7 +21,7 @@ def __init__(
             self.consumer = AIOKafkaConsumer(
                 api_settings.getKafkaTopicPrefix() + "-triggers",
                 bootstrap_servers=settings.KAFKA_BROKERS,
-                group_id="heartbeat-check-group",
+                group_id=f"{api_settings.getKafkaTopicPrefix()}-heartbeat-check-group",
             )
 
     async def start(self):