org.apache.kafka.clients.admin

Class DescribeReplicaLogDirsResult

java.lang.Object

org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult

@InterfaceStability.Evolving
public class DescribeReplicaLogDirsResult
extends java.lang.Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DescribeReplicaLogDirsResult.ReplicaLogDirInfo

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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