Bill Bejeck created KAFKA-20466:
-----------------------------------
Summary: KIP-892: Implement Generic Transaction Buffer (Phase 0)
Key: KAFKA-20466
URL: https://issues.apache.org/jira/browse/KAFKA-20466
Project: Kafka
Issue Type: Sub-task
Components: streams
Reporter: Bill Bejeck
Fix For: 4.4.0
Deliver the TransactionBuffer abstraction as a standalone, independently
mergeable piece before KIP-892 core work begins.
Files to create:
- state/internals/TransactionBuffer.java — interface
- state/internals/AbstractTransactionBuffer.java — shared
ConcurrentSkipListMap + ReentrantReadWriteLock logic
- state/internals/RocksDBTransactionBuffer.java — RocksDB implementation
(plain WriteBatch)
- state/internals/InMemoryTransactionBuffer.java — in-memory implementation
- state/internals/StagedMergeIterator.java — merge iterator over staging
snapshot + base iterator
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
