diff --git a/src/common/tools/kafka/Variables.py b/src/common/tools/kafka/Variables.py index e3ee2016acc7bc2323733d6781a57c755272bde3..168957a26c4f1947d65d7c849c25ed7e9dad06be 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 40bffa06ef162abdc55e2d4171dfe287ce8febb7..81324b7590c059cf4230f459b3ea1dabf1f4e68e 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 +