Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
public enum CoordinatorType { 
    GROUP((byte) 0), 
    TRANSACTION((byte) 1), 
    SHARE((byte) 2),
    MIRROR((byte) 3); // New type
}

Errors

List of protocol-level errors returned in API responses:

Error CodeNameUsed ByContext
3UNKNOWN_TOPIC_OR_PARTITIONMirrorMetadataManagerSource topic metadata has errors during sync
15COORDINATOR_NOT_AVAILABLEMirrorCoordinatorMirror coordinator is not active
31CLUSTER_AUTHORIZATION_FAILEDKafkaApis, ControllerApisMissing authorization for mirror operations
35UNSUPPORTED_VERSIONKafkaApis, ControllerApisCluster mirroring disabled (mirror.version=0)
38INVALID_REPLICATION_FACTORReplicationControlManagerInsufficient brokers for mirror topic replication
39INVALID_REPLICA_ASSIGNMENTReplicationControlManagerBrokers fenced or in controlled shutdown
42INVALID_REQUESTKafkaApis, ConfigurationControlManagerValidation failures (direct mirror.name modification, mirror disabled, invalid config)

Mirror Metadata Records

LastMirroredOffsets

...