Package org.apache.kafka.clients.admin

Class AlterReplicaLogDirsResult

java.lang.Object

org.apache.kafka.clients.admin.AlterReplicaLogDirsResult

@Evolving
public class AlterReplicaLogDirsResult
extends java.lang.Object

The result of Admin.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions). To retrieve the detailed result per specified TopicPartitionReplica, use values(). To retrieve the overall result only, use all().

Constructor Summary

Constructors

Constructor	Description
AlterReplicaLogDirsResult(java.util.Map<TopicPartitionReplica,KafkaFuture<java.lang.Void>> futures)

Method Summary

Modifier and Type	Method	Description
KafkaFuture<java.lang.Void>	all()	Return a KafkaFuture which succeeds on KafkaFuture.get() if all the replica movement have succeeded.
java.util.Map<TopicPartitionReplica,KafkaFuture<java.lang.Void>>	values()	Return a map from TopicPartitionReplica to KafkaFuture which holds the status of individual replica movement.

Methods inherited from class java.lang.Object

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

Constructor Detail

AlterReplicaLogDirsResult

public AlterReplicaLogDirsResult(java.util.Map<TopicPartitionReplica,KafkaFuture<java.lang.Void>> futures)

Method Detail

values

public java.util.Map<TopicPartitionReplica,KafkaFuture<java.lang.Void>> values()

Return a map from TopicPartitionReplica to KafkaFuture which holds the status of individual replica movement. To check the result of individual replica movement, call KafkaFuture.get() from the value contained in the returned map. If there is no error, it will return silently; if not, an Exception will be thrown like the following:

• CancellationException: The task was canceled.
• InterruptedException: Interrupted while joining I/O thread.
• ExecutionException: Execution failed with the following causes:
• ClusterAuthorizationException: Authorization failed. (CLUSTER_AUTHORIZATION_FAILED, 31)
• InvalidTopicException: The specified topic name is too long. (INVALID_TOPIC_EXCEPTION, 17)
• LogDirNotFoundException: The specified log directory is not found in the broker. (LOG_DIR_NOT_FOUND, 57)
• ReplicaNotAvailableException: The replica does not exist on the broker. (REPLICA_NOT_AVAILABLE, 9)
• KafkaStorageException: Disk error occurred. (KAFKA_STORAGE_ERROR, 56)
• UnknownServerException: Unknown. (UNKNOWN_SERVER_ERROR, -1)

all

public KafkaFuture<java.lang.Void> all()

Return a KafkaFuture which succeeds on KafkaFuture.get() if all the replica movement have succeeded. if not, it throws an Exception described in values() method.