dnishimura opened a new pull request #971: SAMZA-2144: In TaskInstance, bypass "SSP caught-up" check if offset is set by a startpoint URL: https://github.com/apache/samza/pull/971 TaskInstance maintains a "SSP caught-up map" to ensure that all tasks for the same SSP have caught up to he same checkpoint offset before processing any messages. However, this does not apply to startpoints since it expects to begin processing messages starting from the startpoint's offset position. @shanthoosh please take a look.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
