diff --git a/producer/proto/producer_nf.go b/producer/proto/producer_nf.go index 4f95f777..e889f4dc 100644 --- a/producer/proto/producer_nf.go +++ b/producer/proto/producer_nf.go @@ -569,6 +569,13 @@ func ConvertNetFlowDataSet(flowMessage *ProtoProducerMessage, version uint16, ba } } else if version == 10 { switch df.Type { + case netflow.IPFIX_FIELD_flowStartSysUpTime: + flowMessage.TimeFlowStartNs = uint64(binary.BigEndian.Uint32(v)) * 1e6 + case netflow.IPFIX_FIELD_flowEndSysUpTime: + flowMessage.TimeFlowEndNs = uint64(binary.BigEndian.Uint32(v)) * 1e6 + case netflow.IPFIX_FIELD_systemInitTimeMilliseconds: + flowMessage.TimeFlowStartNs += binary.BigEndian.Uint64(v) * 1e6 + flowMessage.TimeFlowEndNs += binary.BigEndian.Uint64(v) * 1e6 case netflow.IPFIX_FIELD_flowStartSeconds: if err := DecodeUNumber(v, &time); err != nil { return err