public class TopicInfo extends Object
Constructor and Description |
---|
TopicInfo(String topic,
org.apache.kafka.common.Uuid topicId,
int partitions,
int replicationFactors) |
TopicInfo(String topic,
org.apache.kafka.common.Uuid topicId,
int partitions,
int replicationFactors,
Optional<MirrorTopicInfo> mirrorTopicInfo) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
String |
logicalClusterId() |
Optional<MirrorTopicInfo> |
mirrorTopicInfo() |
int |
partitions() |
int |
replicationFactors() |
org.apache.kafka.common.Uuid |
topicId() |
String |
toString() |
public TopicInfo(String topic, org.apache.kafka.common.Uuid topicId, int partitions, int replicationFactors)
public TopicInfo(String topic, org.apache.kafka.common.Uuid topicId, int partitions, int replicationFactors, Optional<MirrorTopicInfo> mirrorTopicInfo)
public org.apache.kafka.common.Uuid topicId()
public int partitions()
public int replicationFactors()
public Optional<MirrorTopicInfo> mirrorTopicInfo()
public String logicalClusterId()