You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Luke Chen (Jira)" <ji...@apache.org> on 2021/09/02 07:48:00 UTC

[jira] [Created] (KAFKA-13264) backwardFetch in InMemoryWindowStore doesn't return in reverse order

Luke Chen created KAFKA-13264:
---------------------------------

             Summary: backwardFetch in InMemoryWindowStore doesn't return in reverse order
                 Key: KAFKA-13264
                 URL: https://issues.apache.org/jira/browse/KAFKA-13264
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 2.8.0
            Reporter: Luke Chen
            Assignee: Luke Chen


When working on another PR, I found currently, the backwardFetch in InMemoryWindowStore doesn't return in reverse order when there are records in the same window.

ex: window size = 500,

input records:

key: "a", value: "aa", timestamp: 0 ==> will be in [0, 500\] window

key: "b", value: "bb", timestamp: 10 ==> will be in [0, 500\] window

when fetch in forward order:

"a" -> "b", which is expected

when fetch in backward order:

"a" -> "b", which is NOT expected



--
This message was sent by Atlassian Jira
(v8.3.4#803005)