bbejeck opened a new pull request, #21571:
URL: https://github.com/apache/kafka/pull/21571
Summary
- Add RocksDBSessionStoreWithHeaders and
RocksDBTimeOrderedSessionStoreWithHeaders — thin wrappers that extend their
respective base session stores and override query() to throw
UnsupportedOperationException, disabling IQv2 for
header-aware session stores
- Add withHeaders flag to RocksDbSessionBytesStoreSupplier and
RocksDbTimeOrderedSessionBytesStoreSupplier so get() returns the appropriate
store variant; backward-compatible constructors default to false
- Add Stores.persistentSessionStoreWithHeaders() public factory method;
both it and the existing persistentSessionStore() now delegate to a shared
private method with a withHeaders flag, following the same pattern as the window
store factories
- Add StoreType entries in AbstractSessionBytesStoreTest so the full
session store test suite runs against the WithHeaders variants
- Add standalone tests verifying the query() UOE behavior for both store
types
Test plan
- Existing session store tests pass (*SessionStore*, *TimeOrderedSession*)
- New RocksDBSessionStoreWithHeadersTest and
RocksDBTimeOrderedSessionStoreWithHeadersTest pass
- AbstractSessionBytesStoreTest subtypes exercising the new StoreType
entries pass
- Stores compiles and existing Stores tests pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
