This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from f503aa3ab49 KAFKA-14491: [16/N] Add recovery logic for store
inconsistency due to failed write (#13364)
add 63fee01366e KAFKA-14491: [19/N] Combine versioned store RocksDB
instances into one (#13431)
No new revisions were added by this update.
Summary of changes:
.../state/internals/LogicalKeyValueSegment.java | 10 +-
.../state/internals/LogicalKeyValueSegments.java | 62 ++++
.../streams/state/internals/RocksDBStore.java | 26 +-
.../state/internals/RocksDBTimestampedStore.java | 2 +-
.../state/internals/RocksDBVersionedStore.java | 22 +-
.../internals/LogicalKeyValueSegmentTest.java | 350 ++++++++++++++++-----
.../internals/LogicalKeyValueSegmentsTest.java | 67 +++-
.../streams/state/internals/RocksDBStoreTest.java | 5 +-
8 files changed, 440 insertions(+), 104 deletions(-)
