Added id code and removed from name
Added funtionality to consumer and send kpi events to onap
Change-Id: I0849e3b9188b1fa53210c341f1fc6e6228c5de9b
Signed-off-by: William Kurkian <wkurkian@cisco.com>
diff --git a/src/main/java/config/Config.java b/src/main/java/config/Config.java
index ec27cfa..cce3045 100644
--- a/src/main/java/config/Config.java
+++ b/src/main/java/config/Config.java
@@ -60,10 +60,14 @@
public static String getKafkaPort() {
return get("kafka_port");
+ }
+
+ public static String getKafkaAlarmsTopic() {
+ return get("kafka_alarms_topic");
}
- public static String getKafkaTopic() {
- return get("kafka_topic");
+ public static String getKafkaKpisTopic() {
+ return get("kafka_kpis_topic");
}
public static String getCoId() {
@@ -73,4 +77,4 @@
public static String getPodId() {
return get("pod_id");
}
-}
+}