Skip to content

KAFKA-20308: Update TopologyTestDriver to support for headers-aware stores#21745

Merged
mjsax merged 2 commits intoapache:trunkfrom
aliehsaeedii:ttd_update
Mar 15, 2026
Merged

KAFKA-20308: Update TopologyTestDriver to support for headers-aware stores#21745
mjsax merged 2 commits intoapache:trunkfrom
aliehsaeedii:ttd_update

Conversation

@aliehsaeedii
Copy link
Copy Markdown
Contributor

@aliehsaeedii aliehsaeedii commented Mar 13, 2026

This PR adds full TopologyTestDriver support for headers-aware state
stores, enabling tests to both access headers and use the simple
non-headers API automatically.

Reviewers: Matthias J. Sax matthias@confluent.io

@github-actions github-actions bot added triage PRs from the community streams labels Mar 13, 2026
@mjsax mjsax added kip Requires or implements a KIP ci-approved and removed triage PRs from the community labels Mar 14, 2026
}
}

static class ReadOnlyWindowStoreFacadeForHeaders<K, V> implements ReadOnlyWindowStore<K, V> {
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.

Seems this duplicate the class we add via #21743 ?

We should clean this up later.

@mjsax
Copy link
Copy Markdown
Member

mjsax commented Mar 14, 2026

Overall this look good, but it might benefit from also follow the pattern from #21743 and use GenricXxx classes?

@mjsax mjsax merged commit 13df7ed into apache:trunk Mar 15, 2026
23 checks passed
gabriellefu pushed a commit to gabriellefu/kafka that referenced this pull request Mar 30, 2026
…tores (apache#21745)

This PR adds full TopologyTestDriver support for headers-aware state
stores, enabling tests to both access headers and use the simple
non-headers API automatically.

Reviewers: Matthias J. Sax <matthias@confluent.io>
Shekharrajak pushed a commit to Shekharrajak/kafka that referenced this pull request Mar 31, 2026
…tores (apache#21745)

This PR adds full TopologyTestDriver support for headers-aware state
stores, enabling tests to both access headers and use the simple
non-headers API automatically.

Reviewers: Matthias J. Sax <matthias@confluent.io>
nileshkumar3 pushed a commit to nileshkumar3/kafka that referenced this pull request Apr 15, 2026
…tores (apache#21745)

This PR adds full TopologyTestDriver support for headers-aware state
stores, enabling tests to both access headers and use the simple
non-headers API automatically.

Reviewers: Matthias J. Sax <matthias@confluent.io>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci-approved kip Requires or implements a KIP streams

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants