Package org.apache.kafka.clients.admin

Class DescribeReplicaLogDirsResult

java.lang.Object

org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult

@Evolving
public class DescribeReplicaLogDirsResult
extends java.lang.Object

The result of Admin.describeReplicaLogDirs(Collection). The API of this class is evolving, see Admin for details.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DescribeReplicaLogDirsResult.ReplicaLogDirInfo

Constructor Summary

Constructors

Constructor	Description
DescribeReplicaLogDirsResult(java.util.Map<TopicPartitionReplica,KafkaFuture<DescribeReplicaLogDirsResult.ReplicaLogDirInfo>> futures)

Method Summary

Modifier and Type	Method	Description
KafkaFuture<java.util.Map<TopicPartitionReplica,DescribeReplicaLogDirsResult.ReplicaLogDirInfo>>	all()	Return a future which succeeds if log directory information of all replicas are available
java.util.Map<TopicPartitionReplica,KafkaFuture<DescribeReplicaLogDirsResult.ReplicaLogDirInfo>>	values()	Return a map from replica to future which can be used to check the log directory information of individual replicas

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DescribeReplicaLogDirsResult

public DescribeReplicaLogDirsResult(java.util.Map<TopicPartitionReplica,KafkaFuture<DescribeReplicaLogDirsResult.ReplicaLogDirInfo>> futures)

Method Detail

values

public java.util.Map<TopicPartitionReplica,KafkaFuture<DescribeReplicaLogDirsResult.ReplicaLogDirInfo>> values()

Return a map from replica to future which can be used to check the log directory information of individual replicas

all

public KafkaFuture<java.util.Map<TopicPartitionReplica,DescribeReplicaLogDirsResult.ReplicaLogDirInfo>> all()

Return a future which succeeds if log directory information of all replicas are available