From cfed6da9c15d402276cc32ce6faa2c1a91a679ba Mon Sep 17 00:00:00 2001 From: Louis Date: Fri, 1 Sep 2023 15:22:47 -0700 Subject: [PATCH] producer: fix fragment for NetFlow (#215) --- producer/proto/producer_nf.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/producer/proto/producer_nf.go b/producer/proto/producer_nf.go index 0d3b382..19aca72 100644 --- a/producer/proto/producer_nf.go +++ b/producer/proto/producer_nf.go @@ -491,7 +491,7 @@ func ConvertNetFlowDataSet(flowMessage *ProtoProducerMessage, version uint16, ba if err := DecodeUNumber(v, &ipFlags); err != nil { return err } - flowMessage.IpFlags = ipFlags + flowMessage.IpFlags = ipFlags >> 5 case netflow.NFV9_FIELD_IPV6_FLOW_LABEL: if err := DecodeUNumber(v, &(flowMessage.Ipv6FlowLabel)); err != nil { return err