@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 sourceTopic,
int numPartitions,
MirrorTopicDescription.State state,
long stateTimeMs,
List<Long> stoppedLogEndOffsets)
Deprecated.
|
MirrorTopicDescription(String linkName,
UUID linkId,
String sourceTopic,
int numPartitions,
MirrorTopicDescription.State state,
long stateTimeMs,
List<Long> stoppedLogEndOffsets)
Deprecated.
|
MirrorTopicDescription(String linkName,
Uuid linkId,
String sourceTopic,
int numPartitions,
MirrorTopicDescription.State state,
long stateTimeMs,
List<Long> stoppedLogEndOffsets,
Uuid sourceTopicId)
Creates a topic mirror description with the specified parameters.
|
Modifier and Type | Method and Description |
---|---|
Uuid |
clusterLinkId()
The Uuid of the cluster link for the mirror topic.
|
boolean |
equals(Object o) |
int |
hashCode() |
UUID |
linkId()
Deprecated.
|
String |
linkName()
The name of the cluster link for the mirror topic.
|
String |
mirrorTopic()
Deprecated.
|
int |
numPartitions()
The number of partitions for the mirror topic.
|
String |
sourceTopic()
The name of the topic that is being mirrored over the cluster link.
|
Uuid |
sourceTopicId()
The source topic id for the mirror topic, otherwise ZERO_UUID if not known.
|
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() |
@Deprecated public MirrorTopicDescription(String linkName, UUID linkId, String sourceTopic, 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 fromsourceTopic
- 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.@Deprecated public MirrorTopicDescription(String linkName, Uuid linkId, String sourceTopic, 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 fromsourceTopic
- 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 MirrorTopicDescription(String linkName, Uuid linkId, String sourceTopic, int numPartitions, MirrorTopicDescription.State state, long stateTimeMs, List<Long> stoppedLogEndOffsets, Uuid sourceTopicId)
linkName
- the name of the cluster link over which the topic mirrors fromlinkId
- the Uuid of the cluster link over which the topic mirrors fromsourceTopic
- 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.sourceTopicId
- the source topic id for the mirror topic, ZERO_UUID if not knownpublic String linkName()
@Deprecated public UUID linkId()
clusterLinkId()
.public Uuid clusterLinkId()
@Deprecated public String mirrorTopic()
Please use sourceTopic()
.
public String sourceTopic()
public int numPartitions()
public MirrorTopicDescription.State state()
public long stateTimeMs()
public List<Long> stoppedLogEndOffsets()
public Uuid sourceTopicId()