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.
- This solution should be supported in different deployment models of samza viz standalone and yarn and API offerings of samza such as beam, SQL, high-level and low-level API.
- Simplicity. Easy for developers and users to create tools and services to set starting offsets of a given Samza job.
...