From eaa93cd9c1c0255e6f3df1ae04a36eddf988c4e0 Mon Sep 17 00:00:00 2001 From: Brage Date: Mon, 17 Jul 2023 01:32:42 +0200 Subject: [PATCH] Fixed env --- pyMetadata/app.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pyMetadata/app.py b/pyMetadata/app.py index 2f6cc871..aff64ed5 100644 --- a/pyMetadata/app.py +++ b/pyMetadata/app.py @@ -11,7 +11,7 @@ from sources.imdb import metadata as ImdbMetadata # Konfigurer Kafka-forbindelsen bootstrap_servers = os.environ.get("KAFKA_BOOTSTRAP_SERVER") if os.environ.get("KAFKA_BOOTSTRAP_SERVER") != None else "127.0.0.1:9092" consumer_group = os.environ.get("KAFKA_CONSUMER_ID") if os.environ.get("KAFKA_CONSUMER_ID") != None else f"Metadata-{uuid.uuid4()}" -kafka_topic = os.environ.get("KAFKA_BOOTSTRAP_SERVER") if os.environ.get("KAFKA_BOOTSTRAP_SERVER") != None else "127.0.0.1:9092" +kafka_topic = os.environ.get("KAFKA_TOPIC") if os.environ.get("KAFKA_TOPIC") != None else "127.0.0.1:9092" class ProducerDataValueSchema: def __init__(self, referenceId, statusType, errorMessage, data):