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

Posted to commits@samza.apache.org by "Cameron Lee (JIRA)" <ji...@apache.org> on 2019/08/08 19:14:00 UTC

[jira] [Created] (SAMZA-2297) InMemorySystemAdmin offsets are off-by-one in some cases

Cameron Lee created SAMZA-2297:
----------------------------------

             Summary: InMemorySystemAdmin offsets are off-by-one in some cases
                 Key: SAMZA-2297
                 URL: https://issues.apache.org/jira/browse/SAMZA-2297
             Project: Samza
          Issue Type: Bug
            Reporter: Cameron Lee
            Assignee: Cameron Lee


# When a stream is empty for an "InMemory" system, the admin returns that the oldest/newest offset is "0" and the upcoming offset is "1". This means that if consumption starts from the upcoming offset when the job initially saw an empty stream, then the first message would get skipped once messages started getting produced.
 # The "newest" offset returned by the admin is one higher than the offset of the last message in the list. Therefore, consuming from this offset would give no messages.
 # The "upcoming" offset returned by the admin is two higher than the offset of the last message in the list. However, the next message actually gets an offset which is (offset of the last message + 1).



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)