This is an automated email from the ASF dual-hosted git repository.
frankvicky pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 16ce003d1df HOTFIX: fix compilation error (#22646)
16ce003d1df is described below
commit 16ce003d1dfd88c2855eb9216bc40329ce54052f
Author: Matthias J. Sax <[email protected]>
AuthorDate: Tue Jun 23 01:24:38 2026 -0700
HOTFIX: fix compilation error (#22646)
Two PRs got merged in parallel. They don't agree to each other:
-
https://github.com/apache/kafka/commit/1dc4cef0bcade1cfc347af4684dece9c998fa8d4
-
https://github.com/apache/kafka/commit/d2cbb26e2b4dec3fc96c5fb666f74af5104793ca
This PR fixes the introduced compilation error.
Reviewers: Manikumar Reddy <[email protected]>, Lucas Brutschy
<[email protected]>, Chia-Ping Tsai <[email protected]>, Nick
Telford <[email protected]>, TengYao Chi <[email protected]>
---
.../streams/state/internals/RocksDBTransactionBuffer.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTransactionBuffer.java
b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTransactionBuffer.java
index ec7d4cd41bf..6b33217667a 100644
---
a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTransactionBuffer.java
+++
b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTransactionBuffer.java
@@ -175,6 +175,16 @@ class RocksDBTransactionBuffer extends
AbstractTransactionBuffer<Bytes> {
return newBaseIterator(cfHandle, from, to, forward, toInclusive);
}
+ @Override
+ ManagedKeyValueIterator<Bytes, byte[]> newBaseSnapshotIterator(
+ final Bytes from,
+ final Bytes to,
+ final boolean forward,
+ final boolean toInclusive
+ ) {
+ return newBaseIterator(cfHandle, from, to, forward, toInclusive);
+ }
+
private ManagedKeyValueIterator<Bytes, byte[]> newBaseIterator(final
ColumnFamilyHandle cf,
final Bytes
from, final Bytes to,
final
boolean forward, final boolean toInclusive) {
