@Confluent @InterfaceStability.Evolving public class ReplicaStatusResult extends Object
ConfluentAdmin.replicaStatus(Set, ReplicaStatusOptions). The API of this class is evolving, see Admin for details.| Constructor and Description |
|---|
ReplicaStatusResult(Map<TopicPartition,KafkaFuture<PartitionResult>> result) |
| Modifier and Type | Method and Description |
|---|---|
KafkaFuture<Void> | all()Returns a future which succeeds only if all replica status requests succeed. |
KafkaFuture<Map<TopicPartition,PartitionResult>> | allResults()Return a feature that succeeds when all replica status requests have succeed. |
Map<TopicPartition,KafkaFuture<PartitionResult>> | partitionResults() |
Map<TopicPartition,KafkaFuture<List<org.apache.kafka.common.replica.ReplicaStatus>>> | result()Returns a map from topic and partition to the status of each of its replicas. |
public ReplicaStatusResult(Map<TopicPartition,KafkaFuture<PartitionResult>> result)
public Map<TopicPartition,KafkaFuture<List<org.apache.kafka.common.replica.ReplicaStatus>>> result()
public KafkaFuture<Void> all()
public Map<TopicPartition,KafkaFuture<PartitionResult>> partitionResults()
public KafkaFuture<Map<TopicPartition,PartitionResult>> allResults()