SEBA-766-Err-handling-for-exporter
Change-Id: I9b7b775ec8d2b335720b315d470ab83286bf0aa3
diff --git a/topic-exporter.go b/topic-exporter.go
index 7e604b5..f4ae0bf 100644
--- a/topic-exporter.go
+++ b/topic-exporter.go
@@ -16,9 +16,8 @@
import (
"encoding/json"
- "log"
- "github.com/prometheus/client_golang/prometheus"
"gerrit.opencord.org/kafka-topic-exporter/common/logger"
+ "github.com/prometheus/client_golang/prometheus"
)
var (
@@ -447,31 +446,31 @@
kpi := VolthaKPI{}
err := json.Unmarshal(data, &kpi)
if err != nil {
- log.Fatal(err)
+ logger.Error("Invalid msg on voltha.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
}
exportVolthaKPI(kpi)
case "onos.kpis":
kpi := OnosKPI{}
err := json.Unmarshal(data, &kpi)
if err != nil {
- log.Fatal(err)
+ logger.Error("Invalid msg on onos.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
}
exportOnosKPI(kpi)
case "importer.kpis":
kpi := ImporterKPI{}
err := json.Unmarshal(data, &kpi)
if err != nil {
- log.Fatal(err)
+ logger.Error("Invalid msg on importer.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
}
exportImporterKPI(kpi)
case "onos.aaa.stats.kpis":
kpi := OnosAaaKPI{}
err := json.Unmarshal(data, &kpi)
if err != nil {
- log.Fatal(err)
+ logger.Error("Invalid msg on onos.aaa.stats.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data))
}
exportOnosAaaKPI(kpi)
default:
- logger.Warn("Unexpected export. Should not come here")
+ logger.Warn("Unexpected export. Topic [%s] not supported. Should not come here", *topic)
}
}