Package com.linkedin.davinci.kafka.consumer

Class TopicPartitionIngestionInfo

java.lang.Object
com.linkedin.davinci.kafka.consumer.TopicPartitionIngestionInfo
public class TopicPartitionIngestionInfo extends Object

  • Constructor Details

    • TopicPartitionIngestionInfo

      public TopicPartitionIngestionInfo(long latestOffset, long offsetLag, double msgRate, double byteRate, String consumerIdStr, long elapsedTimeSinceLastPollInMs, String versionTopicName)

  • Method Details

    • getLatestOffset

      public long getLatestOffset()

    • getOffsetLag

      public long getOffsetLag()

    • setOffsetLag

      public void setOffsetLag(long offsetLag)

    • getMsgRate

      public double getMsgRate()

    • setMsgRate

      public void setMsgRate(double msgRate)

    • getByteRate

      public double getByteRate()

    • setByteRate

      public void setByteRate(double byteRate)

    • getConsumerIdStr

      public String getConsumerIdStr()

    • setConsumerIdStr

      public void setConsumerIdStr(String consumerIdStr)

    • getElapsedTimeSinceLastPollInMs

      public long getElapsedTimeSinceLastPollInMs()

    • setElapsedTimeSinceLastPollInMs

      public void setElapsedTimeSinceLastPollInMs(long elapsedTimeSinceLastPollInMs)

    • getVersionTopicName

      public String getVersionTopicName()

    • setVersionTopicName

      public void setVersionTopicName(String versionTopicName)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object