Class MirrorLagData

java.lang.Object

io.confluent.kafkarest.entities.v3.MirrorLagData

public abstract class MirrorLagData
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MirrorLagData.Builder

Method Summary

Modifier and Type	Method	Description
static MirrorLagData.Builder	builder()
static MirrorLagData.Builder	fromPartitionLag(Integer partition, Long lag, Long lastSourceFetchHighWatermark)
static com.google.common.collect.ImmutableList<MirrorLagData>	fromPartitionLagInfo(List<TopicPartitionLag> partitionLagList)
abstract Long	getLag()
abstract Long	getLastSourceFetchHighWatermark()
abstract Integer	getPartition()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getPartition

public abstract Integer getPartition()

getLag

public abstract Long getLag()

getLastSourceFetchHighWatermark

public abstract Long getLastSourceFetchHighWatermark()

builder

public static MirrorLagData.Builder builder()

fromPartitionLagInfo

public static com.google.common.collect.ImmutableList<MirrorLagData> fromPartitionLagInfo(List<TopicPartitionLag> partitionLagList)

fromPartitionLag

public static MirrorLagData.Builder fromPartitionLag(Integer partition,
 Long lag,
 Long lastSourceFetchHighWatermark)