THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
package org.apache.kafka.common.errors; /** * An exception that indicates remote storage is not ready to receive the requests yet. */ public class RemoteStorageNotReadyException extends RetriableException { private static final long serialVersionUID = 1L; public RemoteStorageNotReadyException(String message, Throwable cause) { super(message, cause); } public RemoteStorageNotReadyException(String message, Throwable cause) { super(message, cause); } public RemoteStorageNotReadyException(Throwable cause) { super(cause); } public RemoteStorageNotReadyException() { } } |
Proposed Changes
When the metadata is not ready, instead of returning ReplicaNotAvailableException in RemotePartitionMetadataStore, we will return the new RemoteStorageNotReadyException.
...