Index: streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java (revision b9738d4d704401cd9f555502fbcfcebd17dc1618) +++ streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java (date 1564528638000) @@ -266,6 +266,10 @@ return cache.size(); } + public boolean isEmpty() { + return cache.isEmpty(); + } + synchronized Iterator> subMapIterator(final Bytes from, final Bytes to) { return cache.subMap(from, true, to, true).entrySet().iterator(); } Index: streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java (revision b9738d4d704401cd9f555502fbcfcebd17dc1618) +++ streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java (date 1564528638000) @@ -235,7 +235,7 @@ // a put on another cache. So even though the sizeInBytes() is // still > maxCacheSizeBytes there is nothing to evict from this // namespaced cache. - if (cache.size() == 0) { + if (cache.isEmpty()) { return; } cache.evict();