public class ClusterMetadataTopicsSnapshot.ClusterMetadataPartitionSnapshot extends Object implements TopicsMetadataSnapshot.PartitionSnapshot
TopicsMetadataSnapshot.PartitionSnapshot
leveraging the ZK-cluster PartitionInfo
.Constructor and Description |
---|
ClusterMetadataPartitionSnapshot(org.apache.kafka.common.PartitionInfo partitionInfo) |
Modifier and Type | Method and Description |
---|---|
int |
numReplicas() |
int |
partitionId() |
String |
topic() |
public ClusterMetadataPartitionSnapshot(org.apache.kafka.common.PartitionInfo partitionInfo)
public String topic()
topic
in interface TopicsMetadataSnapshot.PartitionSnapshot
public int partitionId()
partitionId
in interface TopicsMetadataSnapshot.PartitionSnapshot
public int numReplicas()
numReplicas
in interface TopicsMetadataSnapshot.PartitionSnapshot