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

@@ -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 })

src/kpi_value_writer/service/MetricWriterToPrometheus.py

@@ -94,3 +94,4 @@ class MetricWriterToPrometheus:
             else:
                 LOGGER.error("Error while pushing metric: {}".format(e))
                 raise
+