既存の Kafka クラスターを使用したインストール
Relational Migrator は、 Kafka Connect を含む既存の Kafka クラスターにインストールできます。 このインストール方法は、 Kafka をすでに実行している場合、 または Kafka のインストールと構成に独自のアプローチがある場合に最適です。
始める前に
Relational Migrator を実行しているコンピューターから Kafka Connect クラスターへの Kafka とネットワーク接続が必要です。
手順
Debezium Source Connect プラグインをインストール
ソース データベース用のソース コネクタ アーカイブをダウンロードします。
Unzip the archive.
debezium-connector.jarファイルをdebezium-connectorディレクトリにコピーします。ダウンロードしたアーカイブから、
debezium-connector.jarファイルをdebezium-connector-xxxKafka Connect の Plugin.pass にある ディレクトリにコピーします Kafka Connect クラスター上。たとえば、/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 の Plugin.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 ファイルのロケーション を参照してください。
プロパティ名 | default | 説明 |
|---|---|---|
spring.profiles.active | ローカル | Relational Migrator は、次のプロファイルで実行できます。
プロファイル値を |
server.port | 8278 | Relation Migrator アプリケーションが実行されるポート。 |
migrator.kafka.bootstrap.servers | No default | これは、既存の Kafka クラスターの 詳細については、「 ワーカー構成のプロパティ 」を参照してください。 |
migrator.kafka.connect.url | No default | {host}:{port}形式を使用する Kafka Connect ホスト URL。 |
migrator.kafka.connect.metrics.jmx.service.url | No default | Kafka 接続 Java 管理拡張機能（JTX） URL 以下に例を挙げます。 |
インストールが成功したことを確認する
Relational Migrator を起動し、ログを確認します。 Kafka プロファイルがアクティブで、エラーがないことを確認します。
logファイルは OS 固有の場所にあります。 詳細については、「 Relational Migrator ファイルのロケーション 」を参照してください。