SIENTIAPDE-1110

Add logging for consumer creation in Kafka activity to enhance traceability of topic management.

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]