DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
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 | ||
|---|---|---|
| ||
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 | ||
|---|---|---|
| ||
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 | ||
|---|---|---|
| ||
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.
...