public enum MirrorTopicError extends Enum<MirrorTopicError>
| Enum Constant and Description |
|---|
ILLEGAL_STATEIllegal state encountered while processing mirror topic. |
NO_ERRORThe mirror topic is not in a persistent failed state. |
NON_MONOTONIC_LOG_APPEND_EPOCHRecords received from source leader with epoch lower than previous epoch in the log. |
NON_MONOTONIC_SOURCE_EPOCHSource leader epoch went backwards, source topic may have been recreated. |
NOT_SETNo reason was provided by the broker because the broker was running an older version. |
RECORD_TOO_LARGERecords received from source leader that are larger than the maximum configured for the cluster link. |
SOURCE_PARTITIONS_DECREASEDSource partition count reduced, source topic may have been recreated. |
SOURCE_TOPIC_ID_CHANGEDSource topic id is different from the persisted source topic id. |
SOURCE_TOPIC_MAY_BE_DELETEDSource topic was not in the metadata response or metadata response contained a partition epoch that is lower than last seen epoch. |
UNEXPECTED_TRUNCATIONTruncation below high watermark with inconsistent epoch offsets. |
UNKNOWNThe error code couldn't be mapped because a new error code was set by a broker with a later version. |
UNSUPPORTED_MESSAGE_FORMATRecords with message format v0 or v1 cannot be replicated using cluster linking since we cannot reliably detect log divergence with these older message formats. |
UNSUPPORTED_MIRROR_STATENewer mirror topic state not supported by a broker still running on older version. |
| Modifier and Type | Method and Description |
|---|---|
short | code() |
static MirrorTopicError | errorOrDefault(MirrorTopicError error, boolean failed) |
static MirrorTopicError | forCode(short code, boolean failed) |
static MirrorTopicError | valueOf(String name)Returns the enum constant of this type with the specified name. |
static MirrorTopicError[] | values()Returns an array containing the constants of this enum type, in the order they are declared. |
public static final MirrorTopicError UNKNOWN
public static final MirrorTopicError NOT_SET
public static final MirrorTopicError NO_ERROR
public static final MirrorTopicError SOURCE_TOPIC_MAY_BE_DELETED
public static final MirrorTopicError SOURCE_TOPIC_ID_CHANGED
public static final MirrorTopicError SOURCE_PARTITIONS_DECREASED
public static final MirrorTopicError NON_MONOTONIC_LOG_APPEND_EPOCH
public static final MirrorTopicError UNEXPECTED_TRUNCATION
public static final MirrorTopicError UNSUPPORTED_MESSAGE_FORMAT
public static final MirrorTopicError NON_MONOTONIC_SOURCE_EPOCH
public static final MirrorTopicError ILLEGAL_STATE
public static final MirrorTopicError UNSUPPORTED_MIRROR_STATE
public static final MirrorTopicError RECORD_TOO_LARGE
public static MirrorTopicError[] values()
for (MirrorTopicError c : MirrorTopicError.values()) System.out.println(c);
public static MirrorTopicError valueOf(String name)
name - the name of the enum constant to be returned.IllegalArgumentException - if this enum type has no constant with the specified nameNullPointerException - if the argument is nullpublic short code()
public static MirrorTopicError forCode(short code, boolean failed)
public static MirrorTopicError errorOrDefault(MirrorTopicError error, boolean failed)