@InterfaceStability.Evolving public class DescribeLogDirsResult extends java.lang.Object
AdminClient.describeLogDirs(Collection) call.
The API of this class is evolving, see AdminClient for details.| Constructor and Description |
|---|
DescribeLogDirsResult(java.util.Map<java.lang.Integer,KafkaFuture<java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> futures) |
| Modifier and Type | Method and Description |
|---|---|
KafkaFuture<java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> |
all()
Return a future which succeeds only if all the brokers have responded without error
|
java.util.Map<java.lang.Integer,KafkaFuture<java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> |
values()
Return a map from brokerId to future which can be used to check the information of partitions on each individual broker
|
public DescribeLogDirsResult(java.util.Map<java.lang.Integer,KafkaFuture<java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> futures)
public java.util.Map<java.lang.Integer,KafkaFuture<java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> values()
public KafkaFuture<java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> all()