diff --git a/plugins/outputs/influxdb_v2/http.go b/plugins/outputs/influxdb_v2/http.go
index 3bb60a07..3aeb8a60 100644
--- a/plugins/outputs/influxdb_v2/http.go
+++ b/plugins/outputs/influxdb_v2/http.go
@@ -220,6 +220,12 @@ func (c *httpClient) writeBatch(ctx context.Context, bucket string, metrics []te
 
 	req.GetBody = func() (io.ReadCloser, error) {
 		body := influx.NewReader(metrics, c.serializer)
+		if c.ContentEncoding == "gzip" {
+			body, err = internal.CompressWithGzip(body)
+			if err != nil {
+				return nil, err
+			}
+		}
 		rc := ioutil.NopCloser(body)
 		return rc, nil
 	}