public enum MirrorTopicError extends Enum<MirrorTopicError>
Enum Constant and Description |
---|
ILLEGAL_STATE
Illegal state encountered while processing mirror topic.
|
NO_ERROR
The mirror topic is not in a persistent failed state.
|
NON_MONOTONIC_LOG_APPEND_EPOCH
Records received from source leader with epoch lower than previous epoch in the log.
|
NON_MONOTONIC_SOURCE_EPOCH
Source leader epoch went backwards, source topic may have been recreated.
|
NOT_SET
No reason was provided by the broker because the broker was running an older version.
|
RECORD_TOO_LARGE
Records received from source leader that are larger than the maximum configured for the cluster link.
|
SOURCE_PARTITIONS_DECREASED
Source partition count reduced, source topic may have been recreated.
|
SOURCE_TOPIC_ID_CHANGED
Source topic id is different from the persisted source topic id.
|
SOURCE_TOPIC_MAY_BE_DELETED
Source topic was not in the metadata response or metadata response contained a partition epoch
that is lower than last seen epoch.
|
TRUNCATION_BELOW_HIGH_WATERMARK
Truncation below high watermark.
|
UNEXPECTED_TRUNCATION
Truncation below high watermark with inconsistent epoch offsets.
|
UNKNOWN
The error code couldn't be mapped because a new error code was set by a broker with a later version.
|
UNSUPPORTED_MESSAGE_FORMAT
Records 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_STATE
Newer 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) |
boolean |
repairable() |
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 final MirrorTopicError TRUNCATION_BELOW_HIGH_WATERMARK
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 boolean repairable()
public static MirrorTopicError forCode(short code, boolean failed)
public static MirrorTopicError errorOrDefault(MirrorTopicError error, boolean failed)