Confluent Cloud を使用したインストール

Confluent クラウド環境を作成する

Goクラウド への移行 新しい環境を作成します。

スキーマ レジストリを有効にする

スキーマ レジストリを有効にし、リージョンを選択します。

移行するテーブルが1000を超える場合は、高度なスキーマ レジストリ階層を使用します。 それ以外の場合は、必要最低限の階層で十分です。

クラスターの作成

Environmentページに移動します。 Add Clusterをクリックします。

基本階層クラスターと標準階層クラスターはほとんどのユースケースで十分有効です。 大規模なデータを移行する場合は、専用クラスター階層を検討してください。

権限を設定し、API キーを収集する

Relational Migrator を構成するには、Cloud API キーと Kafka クラスター API キーを構成して収集する必要があります。 これらは user.propertiesファイルに含める必要があります。 user.propertiesファイルの場所は、オペレーティング システムによって異なります。 詳細については、 Relational Migrator ファイルのロケーション を参照してください。

次の API キーは、Confluent Cloud コンソールにあります。 詳しくは、「 API キーの使用 」を参照してください。

1. Confluent Cloud API キーの設定

   Confluent コンソールの右上隅にある次をクリックします:アイコン。 Administrationの下でCloud API Keys を選択します。

   Confluent Cloud API キーを作成し、その権限を設定します。 次の 2 つの権限オプションがあります。

   • グローバル アクセスの許可。

   • サービス アカウントを作成し、詳細なアクセス権を付与します。

   サービス アカウントを作成する場合は、環境用のOperatorロールとクラスターにCloudClusterAdminロールを追加する必要があります。

   作成したら、API キーとシークレットを保存します。 これらの値は、user.properties migrator.confluent.cloud-credentials.api-keyとmigrator.confluent.cloud-credentials.api-secret として ファイルに追加されます。

   詳細については、「 API キーを使用して Confluent Cloud のアクセスを制御する 」を参照してください。

2. Kafka クラスター API キーの構成

   Kafka クラスターにアクセスするには、 Kafka クラスター API キーを設定する必要があります。 Cluster Overviewに移動します。 左側のパネルで、 API Keysをクリックして Kafka クラスター API キーを作成します。

   API キーとシークレットを保存します。 これらの値は、user.properties migrator.confluent.kafka-credentials.api-keyとmigrator.confluent.kafka-credentials.api-secret として ファイルに追加されます。

   詳細については、「 API キーを使用して Confluent Cloud のアクセスを制御する 」を参照してください。

詳細な構成情報を収集する

環境 ID、クラスター ID、ブートストラップ サーバー、クラスター REST エンドポイントは、Confluent Cloud コンソールで確認できます。 詳しくは、 「 Confluent クラウドドキュメント」 を参照してください。

1. 環境 ID を検索して保存します

   Environmentsの概要ページから、クラウド環境を選択します。 環境 ID は、右側のパネルの環境名の下にあります。

   一般的な環境 ID の形式は次のとおりです。

   env-ab1cde

2. クラスター ID を検索して保存します

   Cluster Overviewページに移動し、右側の情報パネルでクラスター ID を見つけます。

   一般的なクラスター ID の形式は次のとおりです。

   abc-1test2

3. クラスターのブートストラップ サーバーを見つけて保存する

   Cluster Overviewページから、左側のナビゲーションを使用して [ Cluster Settings ] をクリックします。 [ Cluster Settingsページで、クラスターのブートストラップ サーバーを見つけます。

   一般的なブートストラップ サーバーの形式は次のとおりです。

   xxx-xxxxx.region.provider.confluent.cloud:9092

4. クラスター REST エンドポイントを見つけて保存する

   Cluster Settingsページで、クラスターの REST エンドポイントを見つけます。

   一般的な REST エンドポイントの形式は次のとおりです。

   https://xxx-xxxxx.region.provider.confluent.cloud:443

構成プロパティをuser.properties ファイルに追加する

user.propertiesファイルのロケーションは、オペレーティング システムによって異なります。 詳細については、「 Relational Migrator ファイルのロケーション 」を参照してください。

次の例を使用して、 user.propertiesファイルに構成プロパティを追加します。

spring.profiles.active: confluent
migrator.confluent.environment.environment-id: <Environment ID>
migrator.confluent.environment.cluster-id: <Cluster ID>
migrator.confluent.environment.bootstrap-server: <xx.region.provider.confluent.cloud:9092>
migrator.confluent.environment.rest-endpoint: <https://xxx.region.provider.confluent.cloud:443>
migrator.confluent.cloud-credentials.api-key: <Cloud API key>
migrator.confluent.cloud-credentials.api-secret: <Cloud API Secret>
migrator.confluent.kafka-credentials.api-key: <Cluster API key>
migrator.confluent.kafka-credentials.api-secret: <Cluster API Secret>

Relational Migrator を再起動する

Relational Migrator を終了し、再起動します。

インストールが成功したことを確認する

Relational Migrator を起動します。 プロジェクトで、 Data Migrationタブに移動します。 インストールが成功した場合、右上隅にはConfluent Deployment model記号が表示されます。

エラーが表示された場合は、 logファイルを確認してください。 logファイルのロケーションは OS によって異なります。 詳細については、「 Relational Migrator ファイルのロケーション 」を参照してください。

クリックして拡大します