6.5. 部署 Kafka MirrorMaker
Cluster Operator 部署一个或多个 Kafka MirrorMaker 副本,以便在 Kafka 集群间复制数据。此过程称为镜像(mirror),以避免与 Kafka 分区复制概念混淆。MirrorMaker 使用来自源集群的消息,并将这些消息重新发布到目标集群。
6.5.1. 将 Kafka MirrorMaker 部署到 OpenShift 集群
此流程演示了如何使用 Cluster Operator 将 Kafka MirrorMaker 集群部署到 OpenShift 集群。
					部署使用 YAML 文件来提供规范来创建 KafkaMirrorMaker 或 KafkaMirrorMaker2 资源,具体取决于部署的 MirrorMaker 版本。
				
						在 Apache Kafka 3.0.0 中已弃用 Kafka MirrorMaker 1 (正如文档中的 imagesMaker),并将在 Apache Kafka 4.0.0 中删除。因此,在 AMQ Streams 中还已弃用了用于部署 Kafka MirrorMaker 1 的 KafkaMirrorMaker 自定义资源。当使用 Apache Kafka 4.0.0 时,KafkaMirrorMaker 资源将从 AMQ Streams 中删除。作为替代方法,在 IdentityReplicationPolicy 中使用 KafkaMirrorMaker2 自定义资源。
					
AMQ Streams 提供示例配置文件。在此过程中,我们使用以下示例文件:
- 
							examples/mirror-maker/kafka-mirror-maker.yaml
- 
							examples/mirror-maker/kafka-mirror-maker-2.yaml
流程
- 将 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! - Toggle word wrap Toggle overflow - 对于 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! - Toggle word wrap Toggle overflow 
- 检查部署的状态: - oc get deployments -n <my_cluster_operator_namespace> - oc get deployments -n <my_cluster_operator_namespace>- Copy to Clipboard Copied! - Toggle word wrap Toggle overflow - 输出显示了部署名称和就绪状态 - NAME READY UP-TO-DATE AVAILABLE my-mirror-maker-mirror-maker 1/1 1 1 my-mm2-cluster-mirrormaker2 1/1 1 1 - NAME READY UP-TO-DATE AVAILABLE my-mirror-maker-mirror-maker 1/1 1 1 my-mm2-cluster-mirrormaker2 1/1 1 1- Copy to Clipboard Copied! - Toggle word wrap Toggle overflow - my-mirror-maker是 Kafka MirrorMaker 集群的名称。- my-mm2-cluster是 Kafka MirrorMaker 2.0 集群的名称。- READY显示 ready/expected 的副本数量。当- AVAILABLE输出显示为- 1时,部署成功。