Index: streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java (revision f62bcac1e6c6ed04a35699062807317e74b938d9) +++ streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java (revision ) @@ -20,6 +20,7 @@ import org.apache.kafka.streams.processor.TimestampExtractor; import java.util.HashMap; +import java.util.LinkedHashMap; import java.util.Map; /** @@ -105,7 +106,7 @@ @Override public Map windowsFor(final long timestamp) { long windowStart = (Math.max(0, timestamp - sizeMs + advanceMs) / advanceMs) * advanceMs; - final Map windows = new HashMap<>(); + final Map windows = new LinkedHashMap<>(); while (windowStart <= timestamp) { final TimeWindow window = new TimeWindow(windowStart, windowStart + sizeMs); windows.put(windowStart, window);