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

java.lang.Object

io.confluent.kafkarest.entities.Mirror

public abstract class Mirror extends Object

Method Summary

Modifier and Type

Method

Description

static Mirror

create(String linkName, String mirrorTopicName, String sourceTopicName, int numPartitions, List<TopicPartitionLag> mirrorLagList, org.apache.kafka.clients.admin.MirrorTopicDescription.State mirrorStatus, org.apache.kafka.common.MirrorTopicError mirrorTopicError, long statusTimeMs, List<Long> stoppedLogEndOffsets, List<org.apache.kafka.clients.admin.ClusterLinkTaskError> mirrorStateTransitionErrors)

abstract String

getLinkName()

abstract List<org.apache.kafka.clients.admin.ClusterLinkTaskError>

getMirrorStateTransitionErrors()

abstract org.apache.kafka.clients.admin.MirrorTopicDescription.State

getMirrorStatus()

abstract org.apache.kafka.common.MirrorTopicError

getMirrorTopicError()

abstract String

getMirrorTopicName()

abstract int

getNumPartitions()

abstract List<TopicPartitionLag>

getPartitionLagList()

abstract String

getSourceTopicName()

abstract long

getStatusTimeMs()

abstract List<Long>

getStoppedLogEndOffsets()

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

Method Details
- getLinkName
  
  public abstract String getLinkName()
- getMirrorTopicName
  
  public abstract String getMirrorTopicName()
- getSourceTopicName
  
  public abstract String getSourceTopicName()
- getNumPartitions
  
  public abstract int getNumPartitions()
- getPartitionLagList
  
  public abstract List<TopicPartitionLag> getPartitionLagList()
- getMirrorStatus
  
  public abstract org.apache.kafka.clients.admin.MirrorTopicDescription.State getMirrorStatus()
- getMirrorTopicError
  
  public abstract org.apache.kafka.common.MirrorTopicError getMirrorTopicError()
- getStatusTimeMs
  
  public abstract long getStatusTimeMs()
- getStoppedLogEndOffsets
  
  public abstract List<Long> getStoppedLogEndOffsets()
- getMirrorStateTransitionErrors
  
  public abstract List<org.apache.kafka.clients.admin.ClusterLinkTaskError> getMirrorStateTransitionErrors()
- create
  
  public static Mirror create(String linkName, String mirrorTopicName, String sourceTopicName, int numPartitions, List<TopicPartitionLag> mirrorLagList, org.apache.kafka.clients.admin.MirrorTopicDescription.State mirrorStatus, org.apache.kafka.common.MirrorTopicError mirrorTopicError, long statusTimeMs, List<Long> stoppedLogEndOffsets, List<org.apache.kafka.clients.admin.ClusterLinkTaskError> mirrorStateTransitionErrors)