diff --git a/plugins/parsers/influx/parser.go b/plugins/parsers/influx/parser.go index 0b16a2a39..b236a6f10 100644 --- a/plugins/parsers/influx/parser.go +++ b/plugins/parsers/influx/parser.go @@ -63,6 +63,7 @@ func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error) { for p.machine.ParseLine() { err := p.machine.Err() if err != nil { + p.handler.Reset() return nil, &ParseError{ Offset: p.machine.Position(), msg: err.Error(),