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]