DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block | ||
|---|---|---|
| ||
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 Code | Name | Used By | Context |
|---|---|---|---|
| 3 | UNKNOWN_TOPIC_OR_PARTITION | MirrorMetadataManager | Source topic metadata has errors during sync |
| 15 | COORDINATOR_NOT_AVAILABLE | MirrorCoordinator | Mirror coordinator is not active |
| 31 | CLUSTER_AUTHORIZATION_FAILED | KafkaApis, ControllerApis | Missing authorization for mirror operations |
| 35 | UNSUPPORTED_VERSION | KafkaApis, ControllerApis | Cluster mirroring disabled (mirror.version=0) |
| 38 | INVALID_REPLICATION_FACTOR | ReplicationControlManager | Insufficient brokers for mirror topic replication |
| 39 | INVALID_REPLICA_ASSIGNMENT | ReplicationControlManager | Brokers fenced or in controlled shutdown |
| 42 | INVALID_REQUEST | KafkaApis, ConfigurationControlManager | Validation failures (direct mirror.name modification, mirror disabled, invalid config) |
Mirror Metadata Records
LastMirroredOffsets
...