Interface Offset

  • All Superinterfaces:
    java.io.Serializable

    @Stable
    public interface Offset
    extends java.io.Serializable
    Interface for implementations and their offset.
    • Method Detail

      • getPartition

        Partition getPartition()
        Which partition is this offset for
        Returns:
        partition of offset
      • getWatermark

        long getWatermark()
        Retrieve watermark associated with this offset.
        Returns:
        watermark associated with this offset