public class ClusterMetadataTopicsSnapshot.ClusterMetadataReplicaInfo extends Object implements TopicsMetadataSnapshot.ReplicaInfo
TopicsMetadataSnapshot.ReplicaInfo
leveraging UpdateMetadataRequestData.UpdateMetadataPartitionState
.Constructor and Description |
---|
ClusterMetadataReplicaInfo(org.apache.kafka.common.message.UpdateMetadataRequestData.UpdateMetadataPartitionState state) |
Modifier and Type | Method and Description |
---|---|
List<Integer> |
inSyncReplicas() |
List<Integer> |
observers() |
List<Integer> |
offlineReplicas() |
List<Integer> |
replicas() |
public ClusterMetadataReplicaInfo(org.apache.kafka.common.message.UpdateMetadataRequestData.UpdateMetadataPartitionState state)
public List<Integer> inSyncReplicas()
inSyncReplicas
in interface TopicsMetadataSnapshot.ReplicaInfo
public List<Integer> offlineReplicas()
offlineReplicas
in interface TopicsMetadataSnapshot.ReplicaInfo
public List<Integer> replicas()
replicas
in interface TopicsMetadataSnapshot.ReplicaInfo
public List<Integer> observers()
observers
in interface TopicsMetadataSnapshot.ReplicaInfo