diff --git a/plugins/inputs/netflow/sflow_v5.go b/plugins/inputs/netflow/sflow_v5.go index 693d2d571..4d7a773b7 100644 --- a/plugins/inputs/netflow/sflow_v5.go +++ b/plugins/inputs/netflow/sflow_v5.go @@ -411,8 +411,8 @@ func (d *sflowv5Decoder) decodeRawHeaderSample(record *sflow.SampledHeader) (map fields["dst"] = l.DstIP.String() fields["ip_total_len"] = l.Length case *layers.TCP: - fields["src_port"] = l.SrcPort - fields["dst_port"] = l.DstPort + fields["src_port"] = uint16(l.SrcPort) + fields["dst_port"] = uint16(l.DstPort) fields["tcp_seq_number"] = l.Seq fields["tcp_ack_number"] = l.Ack fields["tcp_window_size"] = l.Window