4.3. 部署 Kafka MirrorMaker
Cluster Operator 部署一个或多个 Kafka 镜像(MirrorMaker)副本,以在 Kafka 集群间复制数据。此过程称为镜像,以避免与 Kafka 分区复制概念混淆。MirrorMaker 使用源集群的信息,并将这些消息重新发布到目标集群。
4.3.1. 将 Kafka MirrorMaker 部署到 OpenShift 集群
此流程演示了如何使用 Cluster Operator 将 Kafka MirrorMaker 集群部署到 OpenShift 集群。
部署使用 YAML 文件提供创建 KafkaMirrorMaker 或
资源规格,具体取决于部署的 MirrorMaker 版本。
KafkaMir
rorMaker2
在这一流程中,我们使用 AMQ Streams 提供的示例文件:
-
examples/mirror-maker/kafka-mirror-maker.yaml
-
examples/mirror-maker/kafka-mirror-maker-2.yaml
有关配置 KafkaMirrorMaker 或
KafkaMirrorMaker2
资源的详情,请参考 使用 AMQ Streams on OpenShift 指南 中的 Kafka MirrorMaker 集群配置。
步骤
将 Kafka MirrorMaker 部署到 OpenShift 集群:
对于 MirrorMaker:
oc apply -f examples/mirror-maker/kafka-mirror-maker.yaml
oc apply -f examples/mirror-maker/kafka-mirror-maker.yaml
Copy to Clipboard Copied! 对于 MirrorMaker 2.0:
oc apply -f examples/mirror-maker/kafka-mirror-maker-2.yaml
oc apply -f examples/mirror-maker/kafka-mirror-maker-2.yaml
Copy to Clipboard Copied! 验证 MirrorMaker 是否已成功部署:
oc get deployments
oc get deployments
Copy to Clipboard Copied!