THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Provide a simple and generic interface to manipulate starting offsets per input stream partition instead of relying on system-specific checkpoint tools and services. This allows flexibility to build REST API layers and tools on top of the common interface.
- Allow defining starting offsets on an input stream by SSP across all tasks or SSP per task.
- Framework level support for various offset types such as, specific offsets and timestamp-based offsets.
- Provide safety by setting starting offsets out-of-band and not directly in the checkpoints.
- Simplicity. Easy for developers and users to create tools and services to set starting offsets of a given Samza job.
...