ableegoldman commented on a change in pull request #9138: URL: https://github.com/apache/kafka/pull/9138#discussion_r476003479
########## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java ########## @@ -163,7 +164,17 @@ public void put(final Bytes key, final byte[] value, final long windowStartTimes @Deprecated @Override public WindowStoreIterator<byte[]> fetch(final Bytes key, final long timeFrom, final long timeTo) { + return fetch(key, timeFrom, timeTo, true); + } + + @Override + public WindowStoreIterator<byte[]> backwardFetch(final Bytes key, final Instant from, final Instant to) { + final long timeFrom = ApiUtils.validateMillisecondInstant(from, prepareMillisCheckFailMsgPrefix(from, "from")); + final long timeTo = ApiUtils.validateMillisecondInstant(to, prepareMillisCheckFailMsgPrefix(to, "to")); Review comment: Ok, feel free to just create a followup ticket to see if we can clean things up. No need to block this PR on it ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org