@InterfaceStability.Evolving public class MirrorTopicDescription extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MirrorTopicDescription.State
The state of the topic mirroring.
|
Constructor and Description |
---|
MirrorTopicDescription(String linkName,
UUID linkId,
String mirrorTopic,
int numPartitions,
MirrorTopicDescription.State state,
long stateTimeMs,
List<Long> stoppedLogEndOffsets)
Creates a topic mirror description with the specified parameters.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
UUID |
linkId()
The UUID of the cluster link for the mirror topic.
|
String |
linkName()
The name of the cluster link for the mirror topic.
|
String |
mirrorTopic()
The name of the topic that is being mirrored over the cluster link.
|
int |
numPartitions()
The number of partitions for the mirror topic.
|
MirrorTopicDescription.State |
state()
The current state of topic mirroring.
|
long |
stateTimeMs()
The time, in milliseconds from epoch, when the last state transition happened.
|
List<Long> |
stoppedLogEndOffsets()
The set of log end offsets when the mirror topic is stopped in the ascending order of the
partition ids.
|
String |
toString() |
public MirrorTopicDescription(String linkName, UUID linkId, String mirrorTopic, int numPartitions, MirrorTopicDescription.State state, long stateTimeMs, List<Long> stoppedLogEndOffsets)
linkName
- the name of the cluster link over which the topic mirrors fromlinkId
- the UUID of the cluster link over which the topic mirrors frommirrorTopic
- the name of the topic on the source cluster that's mirrorednumPartitions
- the number of partitions for the mirror topicstate
- the state of topic mirroringstateTimeMs
- the time, in milliseconds from epoch, when the last state
transition happenedstoppedLogEndOffsets
- the list of log end offsets at which mirror topic is stopped
for each partition id in ascending order.public String linkName()
public UUID linkId()
public String mirrorTopic()
public int numPartitions()
public MirrorTopicDescription.State state()
public long stateTimeMs()
public List<Long> stoppedLogEndOffsets()