Skip to content

feat(outputs.kafka): Add support for custom record headers#18829

Open
srebhan wants to merge 1 commit intoinfluxdata:masterfrom
srebhan:kafka_issue_16163
Open

feat(outputs.kafka): Add support for custom record headers#18829
srebhan wants to merge 1 commit intoinfluxdata:masterfrom
srebhan:kafka_issue_16163

Conversation

@srebhan
Copy link
Copy Markdown
Member

@srebhan srebhan commented Apr 30, 2026

Summary

This PR allows to set custom record headers for outgoing Kafka messages based on metric information. Each header value can be a Go template to construct values from metric name, tags or fields. By doing so, it replaces the metric_name_header setting which is now just yet-another-header with {{ .Name }} content.

Checklist

Related issues

resolves #16163

@telegraf-tiger telegraf-tiger Bot added area/kafka feat Improvement on an existing feature such as adding a new setting/mode to an existing plugin plugin/output 1. Request for new output plugins 2. Issues/PRs that are related to out plugins labels Apr 30, 2026
@srebhan srebhan self-assigned this Apr 30, 2026
@telegraf-tiger
Copy link
Copy Markdown
Contributor

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area/kafka feat Improvement on an existing feature such as adding a new setting/mode to an existing plugin plugin/output 1. Request for new output plugins 2. Issues/PRs that are related to out plugins

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Feature Request: output.kafka - Support for Verbose/Complex Kafka Header Structures (e.g., JSON Format)

1 participant