Package org.apache.kafka.common

Enum Class MirrorTopicError

java.lang.Object
java.lang.Enum<MirrorTopicError>
org.apache.kafka.common.MirrorTopicError
All Implemented Interfaces:
Serializable, Comparable<MirrorTopicError>, Constable
public enum MirrorTopicError extends Enum<MirrorTopicError>
Reason for persistent failure of a mirror topic.

  • Enum Constant Details

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

    • TRUNCATION_BELOW_HIGH_WATERMARK

      public static final MirrorTopicError TRUNCATION_BELOW_HIGH_WATERMARK
      Truncation below high watermark. This can be caused by unclean source leader election or other errors like couldn't detect source topic recreation.

  • Method Details

    • values

      public static MirrorTopicError[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared

    • valueOf

      public static MirrorTopicError valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (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 class 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)