name and variable fixes

2025-05-28 09:40:05 -03:00
parent cfb217963b
commit 36a2fbbc13
2 changed files with 4 additions and 1 deletions
--- a/laborious/worker/worker.py
+++ b/laborious/worker/worker.py
@@ -28,7 +28,7 @@ async def main():
    logger.info('Starting Notification Handler...')

    notification_handler = NotificationHandler(
-        servers=os.getenv('KAFKA_SERVERS', 'http://localhost:9092'),
+        servers=os.getenv('KAFKA_BOOTSTRAP_SERVERS', 'http://localhost:9092'),
        logger=logger,
        project_name=os.getenv('PROJECT_NAME', 'laborious'),
        pipeline_name='-',