org.apache.kafka.common

Enum MirrorTopicError

java.lang.Object

java.lang.Enum<MirrorTopicError>

org.apache.kafka.common.MirrorTopicError

All Implemented Interfaces:

Serializable, Comparable<MirrorTopicError>

public enum MirrorTopicError
extends Enum<MirrorTopicError>

Reason for persistent failure of a mirror topic.

Enum Constant Summary

Enum Constants

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.
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.

Method Summary

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.

Methods inherited from class java.lang.Enum

compareTo, equals, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

UNKNOWN

public static final MirrorTopicError UNKNOWN

The error code couldn't be mapped because a new error code was set by a broker with a later version.

NOT_SET

public static final MirrorTopicError NOT_SET

No reason was provided by the broker because the broker was running an older version. Default reason will be used by the client.

NO_ERROR

public static final MirrorTopicError NO_ERROR

The mirror topic is not in a persistent failed state.

SOURCE_TOPIC_MAY_BE_DELETED

public static final MirrorTopicError 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. Topic may have been deleted or cluster link no longer has authorization to describe topic. This is used as the default reason when reason was not set by older brokers.

SOURCE_TOPIC_ID_CHANGED

public static final MirrorTopicError SOURCE_TOPIC_ID_CHANGED

Source topic id is different from the persisted source topic id. Source topic was recreated.

SOURCE_PARTITIONS_DECREASED

public static final MirrorTopicError SOURCE_PARTITIONS_DECREASED

Source partition count reduced, source topic may have been recreated.

NON_MONOTONIC_LOG_APPEND_EPOCH

public static final MirrorTopicError NON_MONOTONIC_LOG_APPEND_EPOCH

Records received from source leader with epoch lower than previous epoch in the log. This indicates source topic recreation or corrupted source logs.

UNEXPECTED_TRUNCATION

public static final MirrorTopicError UNEXPECTED_TRUNCATION

Truncation below high watermark with inconsistent epoch offsets. This indicates source topic recreation or corrupted source logs.

UNSUPPORTED_MESSAGE_FORMAT

public static final MirrorTopicError 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.

NON_MONOTONIC_SOURCE_EPOCH

public static final MirrorTopicError NON_MONOTONIC_SOURCE_EPOCH

Source leader epoch went backwards, source topic may have been recreated.

ILLEGAL_STATE

public static final MirrorTopicError ILLEGAL_STATE

Illegal state encountered while processing mirror topic. This is unexpected and indicates a bug in the implementation.

UNSUPPORTED_MIRROR_STATE

public static final MirrorTopicError UNSUPPORTED_MIRROR_STATE

Newer mirror topic state not supported by a broker still running on older version. This will resolve itself when brokers are upgraded to the newer version that supports the new state.

RECORD_TOO_LARGE

public static final MirrorTopicError RECORD_TOO_LARGE

Records received from source leader that are larger than the maximum configured for the cluster link.

Method Detail

values

public static MirrorTopicError[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (MirrorTopicError c : MirrorTopicError.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static MirrorTopicError valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null

code

public short code()

repairable

public boolean repairable()

forCode

public static MirrorTopicError forCode(short code,
                                       boolean failed)

errorOrDefault

public static MirrorTopicError errorOrDefault(MirrorTopicError error,
                                              boolean failed)