[
https://issues.apache.org/jira/browse/SAMZA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2220.
-----------------------------------
> Startpoints - Fully encapsulate resolution of starting offsets in
> OffsetManager
> -------------------------------------------------------------------------------
>
> Key: SAMZA-2220
> URL: https://issues.apache.org/jira/browse/SAMZA-2220
> Project: Samza
> Issue Type: Improvement
> Reporter: Daniel Nishimura
> Assignee: Daniel Nishimura
> Priority: Major
> Time Spent: 1.5h
> Remaining Estimate: 0h
>
> 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.
> The disconnect is because the resolution of the starting offsets from the
> OffsetManager is handled externally which leads to inconsistency of what the
> starting offset should be.
> This ticket is to fully encapsulate that logic in the OffsetManager.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
