nileshkumar3 opened a new pull request, #22643: URL: https://github.com/apache/kafka/pull/22643
RocksDBTransactionBuffer did not implement newBaseSnapshotIterator(), which AbstractTransactionBuffer requires for non-owner (Interactive Query) scans. This broke trunk compilation after KAFKA-20493 (#22625). Implement the missing method using RocksDB native snapshots (getSnapshot + ReadOptions), mirroring InMemoryTransactionBuffer's owner vs. snapshot split. Non-owner snapshotScan() now uses newBaseSnapshotIterator instead of the live newBaseIterator(). Also extract shared buildBaseIterator() and maybeWrapRangeTombstones() helpers, and add SnapshotReleasingIterator to release the snapshot and ReadOptions when the iterator is closed. -- 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]
