diff --git a/scouter/activities/kafka.py b/scouter/activities/kafka.py
index 8fe1454..64ad62e 100644
--- a/scouter/activities/kafka.py
+++ b/scouter/activities/kafka.py
@@ -15,6 +15,8 @@ class Kafka(BaseActivity):
     def __init__(self, bootstrap_servers: str, polling_time: int,
                  group_id: str, logger: Logger, notification_handler: NotificationHandler):
         self.polling_time = polling_time
+        self.bootstrap_servers = bootstrap_servers
+        self.group_id = group_id
 
         self.kafka_connector = KafkaConsumer(
             bootstrap_servers=bootstrap_servers,