- All Superinterfaces:
- java.io.Serializable
@InterfaceStability.Evolving
public interface PartitionOffset
extends java.io.Serializable
Used for per-partition offsets in continuous processing. ContinuousReader implementations will
provide a method to merge these into a global Offset.
These offsets must be serializable.