Support injecting headers #33517
Support injecting headers #33517
Conversation
|
I am looking at the e2e k8s test failures |
There appears to be some flakiness on |
samiura
force-pushed
the
branch-issue-33260
branch
from
503599b to
a1bd26b
Compare
| // Whether to inject headers or not, default is false. | ||
| InjectHeaders bool `mapstructure:"inject_headers"` | ||
|
|
||
| // list of header complaint with kafka receiver |
There was a problem hiding this comment.
What are the compliant headers? How does a user know which headers are compliant?
There was a problem hiding this comment.
| // list of header complaint with kafka receiver | |
| // headers to inject in kafka messages |
|
This PR was marked stale due to lack of activity. It will be closed in 14 days. |
|
Closed as inactive. Feel free to reopen if this PR is still being worked on. |
| @@ -64,6 +67,14 @@ type Config struct { | |||
| Authentication kafka.Authentication `mapstructure:"auth"` | |||
| } | |||
|
|
|||
| type HeaderInjection struct { | |||
| // Whether to inject headers or not, default is false. | |||
| InjectHeaders bool `mapstructure:"inject_headers"` | |||
There was a problem hiding this comment.
Is this boolean needed? You might not need that, just check any headers are present.
| InjectHeaders bool `mapstructure:"inject_headers"` | ||
|
|
||
| // list of header complaint with kafka receiver | ||
| Headers []string `mapstructure:"headers"` |
There was a problem hiding this comment.
Please add code to set the headers.
|
This PR was marked stale due to lack of activity. It will be closed in 14 days. |
|
Closed as inactive. Feel free to reopen if this PR is still being worked on. |
Description: Injecting headers
Link to tracking Issue:#33260
Testing: Tested locally using Kafka -> Kafka receiver -> otel-collector -> kafka exporter
Documentation: