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)

Reply via email to