9.5. 在旧模式下使用 MirrorMaker 2.0

流程

1. 编辑 MirrorMaker consumer.properties 和 producer.properties 文件，以关闭 MirrorMaker 2.0 功能。

   例如：

   replication.policy.class=org.apache.kafka.mirror.LegacyReplicationPolicy 1
   
   refresh.topics.enabled=false 2
   refresh.groups.enabled=false
   emit.checkpoints.enabled=false
   emit.heartbeats.enabled=false
   sync.topic.configs.enabled=false
   sync.topic.acls.enabled=false

   1

   模拟先前版本的 MirrorMaker。

   2

   MirrorMaker 2.0 功能已禁用，包括内部 检查点 和 心跳 主题

2. 使用您在以前的 MirrorMaker 版本中使用的属性文件保存更改并重启 MirrorMaker：

   su - kafka /opt/kafka/bin/kafka-mirror-maker.sh \
   --consumer.config /opt/kafka/config/consumer.properties \
   --producer.config /opt/kafka/config/producer.properties \
   --num.streams=2

   consumer 属性提供源集群的配置，producer 属性提供目标集群配置。

   MirrorMaker 设置集群间的连接。

3. 在目标集群中启动 ZooKeeper 和 Kafka：

   su - kafka
   /opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties

   su - kafka
   /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

4. 对于目标集群，验证主题是否正在复制：

   /bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --list