diff --git a/plugins/inputs/logparser/logparser.go b/plugins/inputs/logparser/logparser.go index 83f5abd210bdd..db3b1f2b437e3 100644 --- a/plugins/inputs/logparser/logparser.go +++ b/plugins/inputs/logparser/logparser.go @@ -11,6 +11,7 @@ import ( "github.com/influxdata/tail" "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/internal/globpath" + "github.com/influxdata/telegraf/models" "github.com/influxdata/telegraf/plugins/inputs" "github.com/influxdata/telegraf/plugins/parsers" ) @@ -184,6 +185,7 @@ func (l *LogParserPlugin) Start(acc telegraf.Accumulator) error { if err != nil { return err } + models.SetLoggerOnPlugin(l.GrokParser, l.Log) l.wg.Add(1) go l.parser()