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)
