SIENTIAPDE-1110
Enhance Kafka activity initialization by adding bootstrap_servers and group_id attributes for improved configuration management.
This commit is contained in:
@@ -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,
|
||||
|
||||
Reference in New Issue
Block a user