Skip to content

SS-504 - kafka sink: add sink id header to published messages. - #39566

Merged
martykulma merged 1 commit into
MaterializeInc:mainfrom
martykulma:maz-pp-sinkid-header
Oct 6, 2026
Merged

martykulma merged 1 commit into
MaterializeInc:mainfrom
martykulma:maz-pp-sinkid-header

Conversation

@martykulma

Copy link
Copy Markdown
Contributor

If the feature flag is enabled, unconditionally adds a materialize-sink-id header to published messages. The materialize- prefix is reserved. The existing behavior is to drop any user supplied values (i.e. they aren't added to the message). The flag only takes effect on sink startup, which follows the behavior of existing flags.

Adds mzcompose tests to cover publishing with and without the feature enabled.

If the feature flag is enabled, unconditionally adds a `materialize-sink-id`
header to published messages.
@martykulma martykulma changed the title SS-504 - SS-504 - kafka sink: add sink id header to published messages. Oct 5, 2026
@martykulma
martykulma marked this pull request as ready for review October 5, 2026 22:37
@martykulma
martykulma requested review from a team as code owners October 5, 2026 22:37

@peterdukelarsen peterdukelarsen left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

LGTM

@martykulma

Copy link
Copy Markdown
Contributor Author

thanks for the review!

@martykulma
martykulma merged commit 5d95ae2 into MaterializeInc:main Oct 6, 2026
85 checks passed
val-materialize added a commit that referenced this pull request Oct 6, 2026
@bosconi bosconi mentioned this pull request Oct 9, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants