Class LagInfo


  • public class LagInfo
    extends java.lang.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 Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      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.
      long endOffsetPosition()
      Get the end offset position for this store partition's changelog topic on the Kafka brokers.
      boolean equals​(java.lang.Object obj)  
      int hashCode()  
      long offsetLag()
      Get the measured lag between current and end offset positions, for this store partition replica
      java.lang.String toString()  
      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait
    • 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.
        Returns:
        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.
        Returns:
        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
        Returns:
        lag as measured by message offsets
      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object