TopicPartitionLag (ce-kafka-rest-extensions 8.2.0-ce API)

java.lang.Object

io.confluent.kafkarest.entities.TopicPartitionLag

public abstract class TopicPartitionLag extends Object

Method Summary

Modifier and Type

Method

Description

static TopicPartitionLag

create(org.apache.kafka.common.TopicPartition topicPartition, long lag, long lastSourceFetchHighWatermark)

abstract long

getLag()

abstract long

getLastSourceFetchHighWatermark()

abstract org.apache.kafka.common.TopicPartition

getTopicPartition()

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- create
  
  public static TopicPartitionLag create(org.apache.kafka.common.TopicPartition topicPartition, long lag, long lastSourceFetchHighWatermark)
- getTopicPartition
  
  public abstract org.apache.kafka.common.TopicPartition getTopicPartition()
- getLag
  
  public abstract long getLag()
- getLastSourceFetchHighWatermark
  
  public abstract long getLastSourceFetchHighWatermark()