kafkaexporter - support injecting headers

[d-mankowski-synerise]

Component(s)

exporter/kafka

Is your feature request related to a problem? Please describe.

kafkareceiver does support header extraction, e.g.

receivers:
  kafka:
    topic: test
    header_extraction: 
      extract_headers: true
      headers: ["header1", "header2"]

However, kafkaexporter does not support injecting such headers, that could then be read by kafkareceiver.

Use case: we want to have a following setup: applications (send traces to) -> OT Collector -> Kafka -> Grafana Tempo. Grafana Tempo has multi-tenancy enabled, which means, that in order to identify which tenant sends the telemetry, an X-Scope-OrgID header is required.

Note: Tempo is using kafkareceiver internally

Describe the solution you'd like

kafkaexporter should be able to inject custom headers that are in compatible format with what kafkareceiver expects. Config could look like this:

exporters:
  kafka:
    topic: test
    header_injection: 
      inject_headers: true
      headers:
        header1: value1
        header2: value2

Describe alternatives you've considered

No response

Additional context

No response

[github-actions]

Pinging code owners:

• exporter/kafka: @pavolloffay @MovieStoreGuy

See Adding Labels via Comments if you do not have permissions to add labels yourself.

[crobert-1]

It may be preferable to add support for the headers setter extension to this exporter, but I'll defer to others who are better informed here than me.

[samiura]

I will work on this issue.