[
https://issues.apache.org/jira/browse/KAFKA-20308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-20308:
------------------------------------
Component/s: streams
> Update TopologyTestDriver to support for headers-aware stores
> --------------------------------------------------------------
>
> Key: KAFKA-20308
> URL: https://issues.apache.org/jira/browse/KAFKA-20308
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Alieh Saeedi
> Assignee: Alieh Saeedi
> Priority: Major
>
> Problem
> TopologyTestDriver cannot access or test headers-aware state stores
> (TimestampedKeyValueStoreWithHeaders and TimestampedWindowStoreWithHeaders).
> When users add these stores to their topology
> and try to access them in tests using existing methods like
> getKeyValueStore() or getTimestampedKeyValueStore(), they encounter issues:
> 1. No method to retrieve the raw headers-aware store (with headers access)
> 2. Existing getter methods don't recognize headers-aware stores
> 3. Tests cannot write test data or assert on values from headers-aware
> stores
> 4. No way to verify header-related functionality in tests
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
