@InterfaceStability.Evolving public class TopicMirrorDescription extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TopicMirrorDescription.State
The state of the topic mirroring.
|
Constructor and Description |
---|
TopicMirrorDescription(String linkName,
UUID linkId,
String mirrorTopic,
int numPartitions,
TopicMirrorDescription.State state,
long stateTimeMs)
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.
|
TopicMirrorDescription.State |
state()
The current state of topic mirroring.
|
long |
stateTimeMs()
The time, in milliseconds from epoch, when the last state transition happened.
|
String |
toString() |
public TopicMirrorDescription(String linkName, UUID linkId, String mirrorTopic, int numPartitions, TopicMirrorDescription.State state, long stateTimeMs)
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 happenedpublic String linkName()
public UUID linkId()
public String mirrorTopic()
public int numPartitions()
public TopicMirrorDescription.State state()
public long stateTimeMs()