root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

HOTFIX: fix the VersionedKeyValueToBytesStoreAdapter#isOpen API (#13695) 

The VersionedKeyValueToBytesStoreAdapter#isOpen API accidentally returns the value of inner.persistent() when it should be returning inner.isOpen()

Reviewers: Matthias J. Sax <mjsax@apache.org>, Luke Chen <showuon@gmail.com>, Bruno Cadonna <cadonna@apache.org>, Victoria Xia <victoria.xia@confluent.io>
This commit is contained in:
A. Sophie Blee-Goldman 2023-05-10 13:39:15 -07:00 committed by GitHub
parent f17fb75b2d
commit 6d2ad4a383
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueToBytesStoreAdapter.java
View File

@ -115,7 +115,7 @@ public class VersionedKeyValueToBytesStoreAdapter implements VersionedBytesStore
@Override @Override
public boolean isOpen() { public boolean isOpen() {
return inner.persistent(); return inner.isOpen();
} }
@Override @Override