Versions Compared

Key

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

...

This section lists the new values added to existing Kafka type enumerations to support Cluster Mirroring

Config

...

A CLI/user-facing entity type string used by kafka-configs.sh.

Code Block
languagejava
public enum ConfigType {
    // existing types unchanged 
    CLUSTER_MIRROR("mirrors");
}

Config Resource

The resource type that represents the cluster mirror configuration in the metadata log. This is used in Admin API requests (DescribeConfigs, IncrementalAlterConfigs, etc.)

...

Represents a mirror as a configurable resource in cluster metadata. Mirror-level properties such as source cluster bootstrap servers, security credentials are stored under this type, keyed by mirror name.

Code Block
languagejava
public final class ConfigResource
    // ...
    public enum Type {
            // existing types unchanged 
        CLUSTER_MIRROR((byte) 64, "mirror");
    }

Schema Field

...

 A The schema-level annotation for MirrorName string fields in protocol messages. The message generator uses it to validate that mirror name fields across all request/response schemas conform to the expected type.

...

Code Block
languagejava
public enum ResourceType {
    // existing types unchanged
    CLUSTER_MIRROR((byte) 8);

Coordinator

...

A The coordinator type for locating the broker responsible for a given mirror name. The coordinator partition is determined by hashing the mirror name across __mirror_state topic partitions.

...