Skip to content

KAFKA-20307: expose header-stores natively in IQv1#21992

Merged
mjsax merged 1 commit intoapache:trunkfrom
mjsax:kafka-20307-fix-iqv1
Apr 8, 2026
Merged

KAFKA-20307: expose header-stores natively in IQv1#21992
mjsax merged 1 commit intoapache:trunkfrom
mjsax:kafka-20307-fix-iqv1

Conversation

@mjsax
Copy link
Copy Markdown
Member

@mjsax mjsax commented Apr 8, 2026

We previously only added support to query headers stores as plain- or
ts-kv-stores. This PR exposes headers-store with their native type.

Reviewers: Bill Bejeck bbejeck@apache.org

We previously only added support to query headers stores as plain- or ts-kv-stores.
This PR exposes headers-store with their native type.
@mjsax mjsax added streams kip Requires or implements a KIP labels Apr 8, 2026
}
}

// ==================== Custom QueryableStoreTypes ====================
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

Why remove this?

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

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

Because we don't need it any longer. We only needed to add it, because we did not have QueryableStoreTypes.TimestampedKeyValueStoreWithHeadersType yet.

So all calls to new TimestampedKeyValueStoreWithHeadersType can be replaced with QueryableStoreTypes.timestampedWindowStoreWithHeaders() to use the built-in functionality of KS now.

@mjsax mjsax merged commit 53629a2 into apache:trunk Apr 8, 2026
26 checks passed
@mjsax mjsax deleted the kafka-20307-fix-iqv1 branch April 8, 2026 16:29
@mjsax
Copy link
Copy Markdown
Member Author

mjsax commented Apr 8, 2026

Merged to trunk and cherry-picked to 4.3 branch.

mjsax added a commit that referenced this pull request Apr 8, 2026
We previously only added support to query headers stores as plain- or
ts-kv-stores. This PR exposes headers-store with their native type.

Reviewers: Bill Bejeck <bbejeck@apache.org>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

kip Requires or implements a KIP streams

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants