confluentinc / confluentinc/ksql
Unable to set header to kafka topic when creating stream from other stream
- Dominant language
- Java
- Stars
- 315
- Forks
- 1k
- Avg merge
- 1d 7h
- Merged PRs (30d)
- 36
Description
We have .net application which publishes the event to kafka topic and on that topic we are creating stream.
There are few headers which get added by default and few are set by code as shown in below image.

We have requirement where we are creating stream from other stream by using "select" statement and set some custom headers.
But issue we are facing here is, all headers which were added to base topic are passed to next topic(using create stream query) and unable to modify these headers.
Contributor guide
Research direction
Start by reproducing the reported case: a .NET application publishes headers to a Kafka topic, then a stream is created from it with a SELECT statement and custom headers. Review the stream-creation and header-handling entry points involved; done means establishing whether inherited headers can be modified and adding coverage for the expected behavior.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka, sql
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100