9.7. (非推奨) レガシーモードでの MirrorMaker 2 の使用

手順

1. MirrorMaker consumer.properties ファイルと producer.properties ファイルを編集して、MirrorMaker 2 機能をオフにします。

   以下に例を示します。

   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 の機能 (内部 チェックポイント および ハートビート トピックを含む) が無効になります

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