From 8cb817b91a43973fb7df008383e46df3d531f3ec Mon Sep 17 00:00:00 2001 From: julien Date: Fri, 12 Apr 2024 17:13:19 +0200 Subject: [PATCH] Changed kafka_conf to only kafka --- src/Conf.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/Conf.py b/src/Conf.py index 60a06e78..bf8abde9 100644 --- a/src/Conf.py +++ b/src/Conf.py @@ -9,12 +9,12 @@ def __init__(self, path: str) -> None: config.read(path) # Accessing values from the configuration file - self.kafka_servers: str = config.get("kafka_conf", "kafka_servers") + self.kafka_servers: str = config.get("kafka", "kafka_servers") self.topic: list[str] = [] - self.topic.append(config.get("kafka_conf", "topic")) - self.group_id: str = config.get("kafka_conf", "group_id") - self.username: str = config.get("kafka_conf", "username") - self.password: str = config.get("kafka_conf", "password") + self.topic.append(config.get("kafka", "topic")) + self.group_id: str = config.get("kafka", "group_id") + self.username: str = config.get("kafka", "username") + self.password: str = config.get("kafka", "password") self.building: str = config.get("building", "name") self.redis_host: str = config.get("redis", "host") self.redis_port: int = int(config.get("redis", "port"))