confluentinc / confluentinc/ksql

Unable to set header to kafka topic when creating stream from other stream

Open
#9,728 5 comments 0 reactions 0 assignees View on GitHub
bug
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.

![TopicHeader](https://user-images.githubusercontent.com/119390255/204540350-b2d0c6cd-067f-44ec-99f7-54c2f3515ddf.JPG)

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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.