Resolve "KPI Management Enhancements"

Closes #176 (closed) and #178 (closed)

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