@InterfaceStability.Evolving public class DescribeLogDirsResult extends java.lang.Object
AdminClient.describeLogDirs(Collection)
call.
The API of this class is evolving, see AdminClient
for details.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 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()