diff --git a/pkg/exporter/ipfix.go b/pkg/exporter/ipfix.go index bac60c64a7b331e148cd5332e3413a5424882edc..8b88ab2068f8941e2ee868d64e459365b6f34377 100644 --- a/pkg/exporter/ipfix.go +++ b/pkg/exporter/ipfix.go @@ -321,9 +321,16 @@ func (ipf *IPFIX) sendDataRecord(log *logrus.Entry, record *flow.Record, v6 bool if err != nil { return err } - err = dataSet.AddRecord(ipf.entitiesV4, templateID) - if err != nil { - return err + if v6 { + err = dataSet.AddRecord(ipf.entitiesV6, templateID) + if err != nil { + return err + } + } else { + err = dataSet.AddRecord(ipf.entitiesV4, templateID) + if err != nil { + return err + } } _, err = ipf.exporter.SendSet(dataSet) if err != nil {