From aca1fe1b241353c4aad9e5fa7dccb99a131794a2 Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Fri, 2 Aug 2024 09:58:58 +0000
Subject: [PATCH] Temporarly defines the static value of env variables to test
the working of microservice.
- KFK_NAMESPACE and KFK_PORT
---
src/common/tools/kafka/Variables.py | 6 ++++--
src/kpi_value_writer/service/MetricWriterToPrometheus.py | 1 +
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/src/common/tools/kafka/Variables.py b/src/common/tools/kafka/Variables.py
index e3ee2016a..168957a26 100644
--- a/src/common/tools/kafka/Variables.py
+++ b/src/common/tools/kafka/Variables.py
@@ -23,8 +23,10 @@ LOGGER = logging.getLogger(__name__)
class KafkaConfig(Enum):
KFK_SERVER_ADDRESS_TEMPLATE = 'kafka-service.{:s}.svc.cluster.local:{:s}'
- KFK_NAMESPACE = get_setting('KFK_NAMESPACE')
- KFK_PORT = get_setting('KFK_SERVER_PORT')
+ KFK_NAMESPACE = 'kafka'
+ # KFK_NAMESPACE = get_setting('KFK_NAMESPACE')
+ KFK_PORT = '9092'
+ # KFK_PORT = get_setting('KFK_SERVER_PORT')
# SERVER_ADDRESS = "127.0.0.1:9092"
SERVER_ADDRESS = KFK_SERVER_ADDRESS_TEMPLATE.format(KFK_NAMESPACE, KFK_PORT)
ADMIN_CLIENT = AdminClient({'bootstrap.servers': SERVER_ADDRESS })
diff --git a/src/kpi_value_writer/service/MetricWriterToPrometheus.py b/src/kpi_value_writer/service/MetricWriterToPrometheus.py
index 40bffa06e..81324b759 100644
--- a/src/kpi_value_writer/service/MetricWriterToPrometheus.py
+++ b/src/kpi_value_writer/service/MetricWriterToPrometheus.py
@@ -94,3 +94,4 @@ class MetricWriterToPrometheus:
else:
LOGGER.error("Error while pushing metric: {}".format(e))
raise
+
--
GitLab