diff --git a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java index 71a31f7dd303f..586ab93809b03 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java @@ -25,6 +25,11 @@ * A window store that only supports read operations. * Implementations should be thread-safe as concurrent reads and writes are expected. * + *

Note: The current implementation of either forward or backward fetches on range-key-range-time does not + * obey the ordering when there are multiple local stores hosted on that instance. For example, + * if there are two stores from two tasks hosting keys {1,3} and {2,4}, then a range query of key [1,4] + * would return in the order of [1,3,2,4] but not [1,2,3,4] since it is just looping over the stores only. + * * @param Type of keys * @param Type of values */