CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(inputs.netflow): Log unknown fields only once (#15323)

This commit is contained in:
Sven Rebhan 2024-05-08 12:13:49 -04:00 committed by GitHub
parent ad16cf4d79
commit 6206693f0c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
plugins/inputs/netflow/netflow_decoder.go
View File

@ -756,6 +756,7 @@ func (d *netflowDecoder) decodeValueV9(field netflow.DataField) ([]telegraf.Fiel
key := fmt.Sprintf("type_%d", elementID) key := fmt.Sprintf("type_%d", elementID)
if !d.logged[key] { if !d.logged[key] {
d.Log.Debugf("unknown Netflow v9 data field %v", field) d.Log.Debugf("unknown Netflow v9 data field %v", field)
d.logged[key] = true
} }
v, err := decodeHex(raw) v, err := decodeHex(raw)
if err != nil { if err != nil {
@ -789,6 +790,7 @@ func (d *netflowDecoder) decodeValueIPFIX(field netflow.DataField) ([]telegraf.F
} }
if !d.logged[key] { if !d.logged[key] {
d.Log.Debugf("unknown IPFIX PEN data field %v", field) d.Log.Debugf("unknown IPFIX PEN data field %v", field)
d.logged[key] = true
} }
name := fmt.Sprintf("type_%d_%s%d", field.Pen, prefix, elementID) name := fmt.Sprintf("type_%d_%s%d", field.Pen, prefix, elementID)
v, err := decodeHex(raw) v, err := decodeHex(raw)
@ -837,6 +839,7 @@ func (d *netflowDecoder) decodeValueIPFIX(field netflow.DataField) ([]telegraf.F
key := fmt.Sprintf("type_%d", elementID) key := fmt.Sprintf("type_%d", elementID)
if !d.logged[key] { if !d.logged[key] {
d.Log.Debugf("unknown IPFIX data field %v", field) d.Log.Debugf("unknown IPFIX data field %v", field)
d.logged[key] = true
} }
v, err := decodeHex(raw) v, err := decodeHex(raw)
if err != nil { if err != nil {