Package org.apache.kafka.clients.admin
Class DescribeLogDirsResult
- java.lang.Object
-
- org.apache.kafka.clients.admin.DescribeLogDirsResult
-
@Evolving public class DescribeLogDirsResult extends java.lang.Object
The result of theAdmin.describeLogDirs(Collection)
call. The API of this class is evolving, seeAdmin
for details.
-
-
Constructor Summary
Constructors Constructor Description DescribeLogDirsResult(java.util.Map<java.lang.Integer,KafkaFuture<java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> futures)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 errorjava.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
-
-
-
Constructor Detail
-
DescribeLogDirsResult
public DescribeLogDirsResult(java.util.Map<java.lang.Integer,KafkaFuture<java.util.Map<java.lang.String,org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo>>> futures)
-
-
Method Detail
-
values
public 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
-
all
public 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
-
-