[elasticexporter] Fix nil panic when setting custom headers (open-tel…

…emetry#16017)

* (bugfix)(elasticexporter) Fix nil panic when setting custom headers

* Added changelog

* Update .chloggen/elasticexporter-fix-custom-header.yaml

Co-authored-by: Pablo Baeyens <[email protected]>

Co-authored-by: Pablo Baeyens <[email protected]>

.chloggen/elasticexporter-fix-custom-header.yaml

@@ -0,0 +1,16 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: bug_fix
+
+# 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: Fixed nil panic error when setting custom headers in elasticsearch exporter
+
+# One or more tracking issues related to the change
+issues: [16017]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:

exporter/elasticsearchexporter/elasticsearch_bulk.go

@@ -84,7 +84,7 @@ func newElasticsearchClient(logger *zap.Logger, config *Config) (*esClientCurren
 
  transport := newTransport(config, tlsCfg)
 
- var headers http.Header
+ headers := make(http.Header)
  for k, v := range config.Headers {
  headers.Add(k, v)
  }

exporter/elasticsearchexporter/logs_exporter_test.go

@@ -110,6 +110,15 @@ func TestExporter_New(t *testing.T) {
  }),
  want: failWithMessage("Addresses and CloudID are set"),
  },
+ "create with custom request header": {
+ config: withDefaultConfig(func(cfg *Config) {
+ cfg.Endpoints = []string{"test:9200"}
+ cfg.Headers = map[string]string{
+ "foo": "bah",
+ }
+ }),
+ want: success,
+ },
  }
 
  for name, test := range tests {