Relational Migrator は、 Kafka Connect などの既存の自己管理型Kafkaクラスターにインストールできます。このインストール方法は、 Kafka をすでに実行中いる場合、 またはKafka のインストールと構成に独自のアプローチがある場合に最適です。
重要
このガイドはKafkaに関する知識があることを前提としています。 このドキュメントとMongoDBサポートでは、 Kafkaクラスターのセットアップ、構成、または管理のサポートは提供されていません。
始める前に
Relational Migrator を実行しているコンピューターから Kafka Connect クラスターへの Kafka とネットワーク接続が必要です。
手順
Debezium Source Connect プラグインをインストール
ソース データベース用のソース コネクタ アーカイブをダウンロードします。
Unzip the archive.
debezium-connector.jarファイルをdebezium-connectorディレクトリにコピーします。ダウンロードしたアーカイブから、
debezium-connector.jarファイルをKafka Connect クラスター上のKafka Connect のプラグイン. パスにあるdebezium-connector-xxxディレクトリにコピーします。例:/kafka/connect/debezium-connector-sqlserver。Kafka Connect クラスターを再起動します。
プラグインが正常に登録されると、
kafka-connect起動ログに次のログ ステートメントが表示されます。INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector'
Relational Migrator Sink Connect プラグインをインストールする
kafka-connect-migrator.jarファイルの最新バージョンをダウンロードします。最新の
kafka-connect-migrator.jarファイルをダウンロードするには、Migrator インストーラー リポジトリ を参照してください。.jarファイルをkafka-connect-migratorディレクトリにコピーします。新しい
kafka-connect-migratorディレクトリは、 Kafka Connect のプラグイン.path にあります。例:/kafka/connect/kafka-connect-migrator。Kafka Connect クラスターを再起動します。
プラグインが正常に登録されると、
kafka-connect起動ログに次のログ ステートメントが表示されます。INFO || Added plugin 'com.mongodb.migrator.kafka.connect.MigratorSinkConnector'
Relational Migrator のインストール
ダウンロード センターから、Relational Migrator インストーラーの最新バージョンを選択します。
Kafka 統合モードで Relational Migrator を実行する
kafka-integratedモードで を実行するには、 user.propertiesファイル内の次の構成を更新します。
user.propertiesファイルは OS 固有の場所にあります。 詳細については、 Relational Migrator ファイルのロケーション を参照してください。
プロパティ名 | 値 |
|---|---|
|
|
| Relation Migrator アプリケーションが実行されるポート。 |
| 既存の Kafka クラスターの 詳細については、「 ワーカー構成のプロパティ 」を参照してください。 |
|
|
| Kafka 接続 Java 管理拡張機能（JTX） URL 以下に例を挙げます。 |
user.propertiesファイルの詳細については、ユーザー プロパティを参照してください。
インストールが成功したことを確認する
Relational Migrator を起動し、ログを確認します。 Kafka プロファイルがアクティブで、エラーがないことを確認します。
logファイルは OS 固有の場所にあります。 詳細については、「 Relational Migrator ファイルのロケーション 」を参照してください。
次のステップ
インストールが成功したことを確認したら、新しいプロジェクトを作成できます。