8.7. 在传统模式中使用 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. 对于目标集群，验证主题是否被复制：

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