Skip to content

feat(output): add custom headers support to kafka - #898

Open
senthilsam wants to merge 4 commits into
openconfig:mainfrom
senthilsam:feat/add_kafka_headers
Open

feat(output): add custom headers support to kafka#898
senthilsam wants to merge 4 commits into
openconfig:mainfrom
senthilsam:feat/add_kafka_headers

Conversation

@senthilsam

@senthilsam senthilsam commented Jul 25, 2026 •
edited
Loading

Copy link
Copy Markdown
Contributor

Added support for adding custom headers to Kafka messages

kafka:
  add-headers:
      env: prod
      sub: '{{ index .Meta "subscription-name" }}'
      source: '{{ index .Meta "source" }}'

@senthilsam
senthilsam force-pushed the feat/add_kafka_headers branch from 3714d5b to 5258504 Compare July 25, 2026 11:25
karimra
karimra requested changes Aug 7, 2026
View reviewed changes

@karimra karimra left a comment

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

please add docs for the added config knob

Comment thread pkg/outputs/kafka_output/kafka_output.go Outdated
Comment thread pkg/outputs/kafka_output/kafka_output.go Outdated
Comment thread pkg/outputs/kafka_output/kafka_output.go Outdated
@senthilsam
senthilsam requested a review from karimra August 15, 2026 04:51
karimra
karimra requested changes Aug 15, 2026
View reviewed changes
Comment thread pkg/outputs/kafka_output/kafka_output.go Outdated
@senthilsam
senthilsam requested a review from karimra August 16, 2026 03:22
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@karimra karimra Awaiting requested review from karimra

Requested changes must be addressed to merge this pull request.

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@senthilsam @karimra