diff --git a/plugins/inputs/influxdb_listener/influxdb_listener.go b/plugins/inputs/influxdb_listener/influxdb_listener.go index 674433db9a38a..0a548221aca3d 100644 --- a/plugins/inputs/influxdb_listener/influxdb_listener.go +++ b/plugins/inputs/influxdb_listener/influxdb_listener.go @@ -347,6 +347,9 @@ func (h *InfluxDBListener) handleWriteUpstreamParser(res http.ResponseWriter, re var err error body, err = gzip.NewReader(body) if err != nil { + if err == influx_upstream.ErrEOF { + return + } h.Log.Debugf("Error decompressing request body: %v", err.Error()) if err := badRequest(res, err.Error()); err != nil { h.Log.Debugf("error in bad-request: %v", err)