From a53804331b6b514666d806b32a432ed43a856c9c Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Mon, 30 Jun 2025 14:36:15 -0300 Subject: [PATCH] SIENTIAPDE-1110 Enhance Kafka activity initialization by adding bootstrap_servers and group_id attributes for improved configuration management. --- scouter/activities/kafka.py | 2 ++ 1 file changed, 2 insertions(+) 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,