You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Bill Bejeck (Jira)" <ji...@apache.org> on 2026/04/17 17:54:00 UTC

[jira] [Created] (KAFKA-20466) KIP-892: Implement Generic Transaction Buffer (Phase 0)

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)