[SAMZA-2220] Startpoints - Fully encapsulate resolution of starting offsets in OffsetManager

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3
• Assignee: Daniel Nishimura
• Reporter: Daniel Nishimura
• Created: 24/May/19 17:06
• Updated: 07/Nov/19 00:06
• Resolved: 17/Jun/19 16:00

Description

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.

Issue Links

• is a child of: SAMZA-1983 SEP-18 : Startpoints implementation in the core framework
• links to: GitHub Pull Request #1053