Adding detailed fields to kafka logs
Change-Id: Ie41f9051ec651aafe57aa2ba30885f7347fc804d
diff --git a/internal/bbsim/responders/igmp/igmp.go b/internal/bbsim/responders/igmp/igmp.go
index 75f2759..defbe19 100644
--- a/internal/bbsim/responders/igmp/igmp.go
+++ b/internal/bbsim/responders/igmp/igmp.go
@@ -167,7 +167,12 @@
}
//Sending IGMP packets
if err := stream.Send(&openolt.Indication{Data: data}); err != nil {
- log.Errorf("Fail to send IGMP PktInd indication for ONU: %s, IntfId: %s, SerialNumber: %s, error: %v", onuId, ponPortId, serialNumber, err)
+ log.WithFields(log.Fields{
+ "OnuId": onuId,
+ "IntfId": ponPortId,
+ "SerialNumber": serialNumber,
+ "err": err,
+ }).Errorf("Fail to send IGMP PktInd indication")
return err
}
return nil