call validate on batcher

Author: VihasMakwana

exporter/elasticsearchexporter/config.go

@@ -274,6 +274,17 @@ func (cfg *Config) Validate() error {
 	if cfg.Retry.MaxRetries < 0 {
 		return errors.New("retry::max_retries should be non-negative")
 	}
+	if cfg.Batcher.Enabled != nil {
+		batcherConfig := exporterbatcher.Config{
+			Enabled:       *cfg.Batcher.Enabled,
+			FlushTimeout:  cfg.Batcher.FlushTimeout,
+			MinSizeConfig: cfg.Batcher.MinSizeConfig,
+			MaxSizeConfig: cfg.Batcher.MaxSizeConfig,
+		}
+		if err := batcherConfig.Validate(); err != nil {
+			return err
+		}
+	}
 
 	return nil
 }

exporter/elasticsearchexporter/config_test.go

@@ -425,6 +425,16 @@ func TestConfig_Validate(t *testing.T) {
 			}),
 			err: `must not specify both retry::max_requests and retry::max_retries`,
 		},
+		"batcher max_size_items less than min_size_items": {
+			config: withDefaultConfig(func(cfg *Config) {
+				cfg.Endpoints = []string{"http://test:9200"}
+				cfg.Batcher.MaxSizeItems = 1000
+				cfg.Batcher.MinSizeItems = 2000
+				enableBatcher := true
+				cfg.Batcher.Enabled = &enableBatcher
+			}),
+			err: `max_size_items must be greater than or equal to min_size_items`,
+		},
 	}
 
 	for name, tt := range tests {

otel.yml

@@ -0,0 +1,29 @@
+exporters:
+  elasticsearch:
+    endpoints: [https://7282951ca2294b1eb34e6bbe3a727140.us-central1.gcp.cloud.es.io:443]
+    timeout: 10s
+    username: fo
+    password: bar
+    sending_queue:
+      enabled: true
+      num_consumers: 2
+      queue_size: 10
+    batcher:
+      enabled: true
+      max_size_items: 1600
+      min_size_items: 5000
+
+
+receivers:
+  otlp:
+    protocols:
+      http:
+        endpoint: "localhost:4318"
+      grpc:
+        endpoint: "localhost:4317"
+
+service:
+  pipelines:
+    logs:
+      receivers: [otlp]
+      exporters: [elasticsearch]