...

Purpose

The purpose of this feature is to To provide a common interface for external tools and services to rewind or and fast-forward the starting offsets on of any input stream . In addition to providing the common interface, this of a samza job. This feature will provide the capabilities to manually manipulate the starting offsets by various position types and not only by specific offsets. Many of the current underlying system consumers support different position types for seeking to an offset on an input stream, such as seeks by timestamp, and are not generically exposed by the current framework.

...