Class LagInfo

  • public class LagInfo
    extends Object
    Encapsulates information about lag, at a store partition replica (active or standby). This information is constantly changing as the tasks process records and thus, they should be treated as simply instantaenous measure of lag.
    • Method Detail

      • currentOffsetPosition

        public long currentOffsetPosition()
        Get the current maximum offset on the store partition's changelog topic, that has been successfully written into the store partition's state store.
        current consume offset for standby/restoring store partitions & simply endoffset for active store partition replicas
      • endOffsetPosition

        public long endOffsetPosition()
        Get the end offset position for this store partition's changelog topic on the Kafka brokers.
        last offset written to the changelog topic partition
      • offsetLag

        public long offsetLag()
        Get the measured lag between current and end offset positions, for this store partition replica
        lag as measured by message offsets
      • hashCode

        public int hashCode()
        hashCode in class Object