diff --git a/plugins/parsers/avro/parser.go b/plugins/parsers/avro/parser.go index 55f9072fa7381..83aebc2007779 100644 --- a/plugins/parsers/avro/parser.go +++ b/plugins/parsers/avro/parser.go @@ -237,7 +237,7 @@ func (p *Parser) createMetric(data map[string]interface{}, schema string) (teleg } var timestamp time.Time if p.Timestamp != "" { - rawTime := fmt.Sprintf("%v", fields[p.Timestamp]) + rawTime := fmt.Sprintf("%v", data[p.Timestamp]) var err error timestamp, err = internal.ParseTimestamp(p.TimestampFormat, rawTime, nil) if err != nil {