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