Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

kafkaexporter - support injecting headers #33260

Open
d-mankowski-synerise opened this issue May 28, 2024 · 4 comments
Open

kafkaexporter - support injecting headers #33260

d-mankowski-synerise opened this issue May 28, 2024 · 4 comments
Assignees
Labels
enhancement New feature or request exporter/kafka

Comments

@d-mankowski-synerise
Copy link

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

@d-mankowski-synerise d-mankowski-synerise added enhancement New feature or request needs triage New item requiring triage labels May 28, 2024
Copy link
Contributor

Pinging code owners:

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

@crobert-1
Copy link
Member

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
Copy link
Contributor

samiura commented Jun 7, 2024

I will work on this issue.

Copy link
Contributor

github-actions bot commented Aug 7, 2024

This issue has been inactive for 60 days. It will be closed in 60 days if there is no activity. To ping code owners by adding a component label, see Adding Labels via Comments, or if you are unsure of which component this issue relates to, please ping @open-telemetry/collector-contrib-triagers. If this issue is still relevant, please ping the code owners or leave a comment explaining why it is still relevant. Otherwise, please close it.

Pinging code owners:

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request exporter/kafka
Projects
None yet
Development

No branches or pull requests

4 participants