Changed kafka_conf to only kafka

42paris · Apr 12, 2024 · 8cb817b · 8cb817b
1 parent 170d594
commit 8cb817b
Showing 1 changed file with 5 additions and 5 deletions.
diff --git 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"))