THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
| Table of Contents |
|---|
This page is meant as a template for writing a KIP. To create a KIP choose Tools->Copy on this page and modify with your content and replace the heading with the next KIP number and a description of your issue. Replace anything in italics with your own description.
Status
Current state: Under Discussion
...
| 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 {
public RemoteStorageNotReadyException(String message, Throwable cause) {
super(message, cause);
}
public RemoteStorageNotReadyException(String message) {
super(message);
}
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.
...