The result of
Admin.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions). To retrieve the detailed result per specified
values(). To retrieve the overall result only, use
valuesReturn a map from
KafkaFuturewhich 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
Exceptionwill 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)