7.5. Kafka MirrorMaker 2 のアイデンティティーレプリケーションポリシー

ID レプリケーションポリシーは、リモートトピックの自動名前変更機能の後継として MirrorMaker 2 で使用される機能です。名前の前にソースクラスターの名前を付ける代わりに、トピックは元の名前を保持します。この設定は、アクティブ/パッシブバックアップおよびデータ移行シナリオに特に役立ちます。

ID レプリケーションポリシーを実装するには、MirrorMaker 2 設定でレプリケーションポリシークラス (replication.policy.class) を指定する必要があります。以前は、Streams for Apache Kafka の mirror-maker-2-extensions コンポーネントに含まれる io.strimzi.kafka.connect.mirror.IdentityReplicationPolicy クラスを指定できました。ただし、このコンポーネントは非推奨となり、今後削除される予定です。したがって、Kafka 独自のレプリケーションポリシークラス (org.apache.kafka.connect.mirror.IdentityReplicationPolicy) を使用するように実装を更新することを推奨します。

Kafka MirrorMaker 2 の設定 を参照してください。