From e7b05ebf3aa78600b5f23c80b2d40e996c9b5bba Mon Sep 17 00:00:00 2001
From: vitor-aignosi <vitor.santos@aignosi.com.br>
Date: Tue, 1 Jul 2025 11:05:03 -0300
Subject: [PATCH] SIENTIAPDE-1110  Add logging for consumer creation in Kafka
 activity to enhance traceability of topic management.

---
 scouter/activities/kafka.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/scouter/activities/kafka.py b/scouter/activities/kafka.py
index 6276455..ea36655 100644
--- a/scouter/activities/kafka.py
+++ b/scouter/activities/kafka.py
@@ -67,6 +67,10 @@ class Kafka(BaseActivity):
         topic = input_data["topic"]
 
         if topic not in self.consumers:
+            self.info(
+                f"Creating consumer for topic: {topic}",
+                metadata=metadata
+            )
             await self.create_consumer(topic)
 
         consumer = self.consumers[topic]