diff --git a/plugins/inputs/reader/reader.go b/plugins/inputs/reader/reader.go index a8bf5c468..274f22a66 100644 --- a/plugins/inputs/reader/reader.go +++ b/plugins/inputs/reader/reader.go @@ -59,6 +59,10 @@ func (r *Reader) Gather(acc telegraf.Accumulator) error { } func (r *Reader) compileParser() { + if r.DataFormat == "" { + log.Printf("E! No data_format specified") + return + } if r.DataFormat == "grok" { log.Printf("Grok isn't supported yet") return