diff --git a/laborious/worker/worker.py b/laborious/worker/worker.py index 4e36cc2..5b902a9 100644 --- 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='-', diff --git a/values.yaml b/values.yaml index 7e60b9f..99c82f5 100644 --- a/values.yaml +++ b/values.yaml @@ -157,6 +157,9 @@ env: - name: OPC_URL value: "opc.tcp://sientia-opc-simulator.sientia.svc.cluster.local:4840" + - name: KAFKA_BOOTSTRAP_SERVERS + value: "kafka.kafka.svc.cluster.local:9092" + - name: LOG_LEVEL value: "DEBUG" - name: PROJECT_NAME