7.5. Kafka MirrorMaker 2 配置
Kafka MirrorMaker 2 在两个或多个活跃 Kafka 集群之间复制数据,并在数据中心之间复制数据。要设置 MirrorMaker 2,源和目标(目标) Kafka 集群必须正在运行。
将数据从源集群镜像 (mirror)到目标集群的过程是异步的。每个 MirrorMaker 2 实例将数据从一个源集群镜像到一个目标集群。您可以使用多个 MirrorMaker 2 实例在任意数量的集群间镜像数据。
图 7.1. 在两个集群间复制
MirrorMaker 2 使用源和目标集群配置,如下所示:
- 用于从源集群消耗数据的源集群配置
- 将数据输出到目标集群的目标集群配置
主题和消费者组复制以逗号分隔的列表或正则表达式模式指定。
显示 MirrorMaker 2 配置的 YAML 示例
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
name: my-mirror-maker2
spec:
version: 3.7.0
connectCluster: "my-cluster-target"
clusters:
- alias: "my-cluster-source"
bootstrapServers: my-cluster-source-kafka-bootstrap:9092
- alias: "my-cluster-target"
bootstrapServers: my-cluster-target-kafka-bootstrap:9092
mirrors:
- sourceCluster: "my-cluster-source"
targetCluster: "my-cluster-target"
sourceConnector: {}
topicsPattern: ".*"
groupsPattern: "group1|group2|group3"