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)