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

Posted to commits@samza.apache.org by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2019/05/24 17:07:00 UTC

[jira] [Created] (SAMZA-2220) Startpoints - sync TaskInstance offset caught up logic with Startpoints

Daniel Nishimura created SAMZA-2220:
---------------------------------------

             Summary: Startpoints - sync TaskInstance offset caught up logic with Startpoints
                 Key: SAMZA-2220
                 URL: https://issues.apache.org/jira/browse/SAMZA-2220
             Project: Samza
          Issue Type: Improvement
            Reporter: Daniel Nishimura
            Assignee: Daniel Nishimura


Currently when a startpoint is set, the consumers are registered with the offset of the startpoints. However, the TaskInstance offset caught up logic also needs to incorporate startpoints or else the incoming messages are ignored up until the checkpointed offset instead of the startpoint offset.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)