[elasticsearchexporter] support compression level

.chloggen/add-compression-level-esexporter.yml

@@ -0,0 +1,13 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: elasticsearchexporter
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Syncs support for compression level on elasticsearch exporter with confighttp. The default compression level is 1 if not set.  
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [37260]

exporter/elasticsearchexporter/README.md

@@ -71,7 +71,7 @@ service:
 
 ### HTTP settings
 
-The Elasticsearch exporter supports common [HTTP Configuration Settings][confighttp]. Gzip compression is enabled by default. To disable compression, set `compression` to `none`.
+The Elasticsearch exporter supports common [HTTP Configuration Settings][confighttp]. Gzip compression is enabled by default. To disable compression, set `compression` to `none`. Default Compression Level is set to 1.
 As a consequence of supporting [confighttp], the Elasticsearch exporter also supports common [TLS Configuration Settings][configtls].
 
 The Elasticsearch exporter sets `timeout` (HTTP request timeout) to 90s by default.

exporter/elasticsearchexporter/bulkindexer.go

@@ -72,7 +72,12 @@
 	}
 	var compressionLevel int
 	if config.Compression == configcompression.TypeGzip {
-		compressionLevel = gzip.BestSpeed
+		if config.CompressionParams.Level {
+			compressionLevel = config.CompressionParams.Level
+		} else {
+			compressionLevel = gzip.BestSpeed
+
+		}
 	}
 	return docappender.BulkIndexerConfig{
 		Client:                client,

exporter/elasticsearchexporter/bulkindexer_test.go

@@ -16,6 +16,7 @@ import (
 	"github.com/elastic/go-elasticsearch/v7"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"go.opentelemetry.io/collector/config/configcompression"
 	"go.opentelemetry.io/collector/config/confighttp"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
@@ -263,6 +264,14 @@ func TestAsyncBulkIndexer_logRoundTrip(t *testing.T) {
 				Flush:        FlushSettings{Interval: time.Hour, Bytes: 1e+8},
 			},
 		},
+		{
+			name: "compression gzip - level 5",
+			config: Config{
+				NumWorkers:   1,
+				ClientConfig: confighttp.ClientConfig{Compression: "gzip", CompressionParams: configcompression.CompresionParams{Level: 5}},
+				Flush:        FlushSettings{Interval: time.Hour, Bytes: 1e+8},
+			},
+		},
 	}
 
 	for _, tt := range tests {