alanlau28 opened a new pull request, #22822: URL: https://github.com/apache/kafka/pull/22822
jira: https://issues.apache.org/jira/browse/KAFKA-20757 Extends KIP-892 transactional state-store (`enable.transactional.statestores`) unit coverage to the store families and buffer paths that lacked it. The existing store behavior suites are re-run through the staged-write / merge-on-read path via the `transactional()` abstract-test hook, added for the key-value and segmented families. Additional unit tests cover the transaction-buffer internals directly. | Area | Coverage | |---|---| | Key-value stores (RocksDB + in-memory) | put/get/range/all/prefixScan/delete/restore re-run through the staged-write / merge path | | Window & session stores (RocksDB incl. time-ordered ± index ± headers; in-memory) | same store contract, windowed | | Segmented bytes stores (+ dual-schema) | multi-segment fetch/range/all & retention via the dual-CF accessor | | In-memory window/session buffers | composite-key ordering, staged read-your-writes, commit flush/cleanup, byte accounting | | RocksDB buffer + RocksDBStore restore | rollback isolation (no cross-key leak); restore bypasses the buffer | -- 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]
