Adding detailed fields to kafka logs
Change-Id: Ie41f9051ec651aafe57aa2ba30885f7347fc804d
diff --git a/internal/common/kafka_utils.go b/internal/common/kafka_utils.go
index 9ddd79c..e907aad 100644
--- a/internal/common/kafka_utils.go
+++ b/internal/common/kafka_utils.go
@@ -62,7 +62,15 @@
for {
select {
case event := <-eventChannel:
- log.Debugf("Received event on channel %v", event)
+ log.WithFields(log.Fields{
+ "EventType": event.EventType,
+ "OnuSerial": event.OnuSerial,
+ "OltID": event.OltID,
+ "IntfID": event.IntfID,
+ "OnuID": event.OnuID,
+ "EpochTime": event.EpochTime,
+ "Timestamp": event.Timestamp,
+ }).Trace("Received event on channel")
jsonEvent, err := json.Marshal(event)
if err != nil {
log.Errorf("Failed to get json event %v", err)
@@ -72,7 +80,15 @@
Topic: topic,
Value: sarama.ByteEncoder(jsonEvent),
}
- log.Debugf("Event sent on kafka")
+ log.WithFields(log.Fields{
+ "EventType": event.EventType,
+ "OnuSerial": event.OnuSerial,
+ "OltID": event.OltID,
+ "IntfID": event.IntfID,
+ "OnuID": event.OnuID,
+ "EpochTime": event.EpochTime,
+ "Timestamp": event.Timestamp,
+ }).Debug("Event sent on kafka")
}
}
}