@InterfaceStability.Evolving public class DescribeLogDirsResult extends Object
Admin.describeLogDirs(Collection)
call.
The API of this class is evolving, see Admin
for details.Modifier and Type | Method and Description |
---|---|
KafkaFuture<Map<Integer,Map<String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> |
all()
Return a future which succeeds only if all the brokers have responded without error
|
Map<Integer,KafkaFuture<Map<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 Map<Integer,KafkaFuture<Map<String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> values()
public KafkaFuture<Map<Integer,Map<String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> all()