Confluent Kafka用のReplicatの追加

Confluent Kafka用のReplicatプロセスの追加について学習します。

Replicatの追加(23ai)

Replicatを追加および実行する前に、このターゲット・タイプに固有の詳細を確認してください

Oracle GoldenGate 23aiでConfluent KafkaのReplicatを追加するには:

1. OCI GoldenGateデプロイメント・コンソールの管理サービスのホームページで、「Replicatの追加」(プラス・アイコン)をクリックします。
2. 「Replicatの追加」パネルのReplicat情報ページで、必要に応じてフィールドに入力し、「次」をクリックします:
   • Replicatタイプを選択します:
     • クラシックReplicat
     • 調整Replicat
   • 「プロセス名」に5文字以下の長さで入力します。
   • 「説明」を入力して、このプロセスを他のプロセスと区別できるようにします。
3. 「Replicatオプション」ページで、必要に応じてフィールドに値を入力し、「次」をクリックします:
   • Replicatトレイル:
     • 「名前」を入力します
     • 証跡ファイルがデフォルト以外の場所にあることが想定される場合は、「サブディレクトリ」を入力します。
     • 暗号化プロファイルを選択します。暗号化プロファイルが作成されていない場合は、デフォルトでローカル・ウォレットが選択されます。
     • 「開始」で、データ処理の開始点を選択します:
       • ログでの位置(デフォルト)
       • Now
       • カスタム時間
   • トレイルの位置:
     • 「連番」を入力します。
     • RBAオフセットを入力します。
     • 「ターゲット」ドロップダウンからKafkaを選択します。
     • Kafka Connectを有効にします。
   • ターゲットの資格証明:
     • 「ドメイン」を選択します
     • 指定したドメイン内の別名を選択します。
     • 「チェックポイント」表を選択します。デフォルトの選択を残すか、ターゲット・デプロイメント用に作成したチェックポイント表を選択します。
     • 「最大スレッド数」を選択します(調整されたレプリカのみ)。
4. 「管理対象オプション」ページで、必要に応じてオプションのフィールドに入力し、「次」をクリックします:
   • プロファイル名がある場合は選択します。
   • デプロイメントのヘルスに不可欠を有効にします。
   • 自動開始設定を有効にして構成します。
5. 「パラメータ・ファイル」ページで、パラメータを追加してReplicatを構成できます。次に例を示します。

   table source.table1;

   調整されたReplicatを使用する場合は、パラメータ・ファイルにTARGETDB LIBFILE libggjava.so SET property=/u02/Deployment/etc/conf/ogg/your_replicat_name.propertiesを追加します。

   ノート:

   GoldenGateでは、デフォルトでグリニッジ標準時(GMT)が使用されます。SETENVを使用して、このReplicatプロセスのデフォルト設定をオーバーライドします。この変更はデプロイメントには適用されません。たとえば次のようにします。

   setenv (TZ="US/Eastern")
   setenv (TZ="GMT+5")

6. 「プロパティ・ファイル」ページで、プロパティを確認し、必要に応じて#TODOとマークされた各プロパティの値が設定されていることを確認します。

   たとえば、gg.handler.kafkahandler.topicMappingTemplate=の場合は、ストリーム名を入力します。

   このターゲットのプロパティの詳細は、Oracle GoldenGate for Distributed Applications and AnalyticsガイドのConfluent Kafka (ターゲット)を参照してください。

7. 「作成および実行」をクリックします。「作成」をクリックすると、後で管理サービスのホーム・ページからReplicatを手動で起動できます。

Replicatの追加(21c)

Oracle Goldengate 21cでConfluent Kafkaターゲット用のReplicatを追加するには:

1. OCI GoldenGateデプロイメント・コンソールの管理サービスの「概要」ページで、「Replicatの追加」(プラス・アイコン)をクリックします。
2. 「Replicatの追加」ページで、Replicatタイプを選択し、「次」をクリックします。
   Replicatのタイプは:

   • クラシックReplicat
   • 調整Replicat
3. 「Replicatオプション」ページで、次のフィールドに入力し、「次」をクリックします:
   1. 「プロセス名」に、Replicatプロセスの名前を入力します。
   2. (オプション)「説明」に、このReplicatを他のReplicatから区別するための簡単な説明を入力します。
   3. 「トレイル名」に、2文字のトレイル名を入力します。
   4. 「ターゲット」で、ドロップダウンから「Kafka」を選択します。
   5. 「使用可能な別名」で、Confluent Kafka接続を選択します。
   6. Kafka Connectを有効にします。
   7. 「コンバータ」で、「Avro」を選択します。
   8. 「スキーマ・レジストリ」で、Confluent Schema Registry接続を選択します。
4. 「パラメータ・ファイル」ページで、必要に応じてReplicatパラメータを追加して構成し、「次」をクリックします。

   ノート:

   GoldenGateでは、デフォルトでグリニッジ標準時(GMT)が使用されます。デフォルト設定をオーバーライドするには、SETENVを使用します。たとえば次のようにします。

   setenv (TZ="US/Eastern")
   setenv (TZ="GMT+5")

   SETENVについてさらに学習します。

5. 「プロパティ・ファイル」ページで、次のKafka Connectプロパティを構成します:
   • gg.handler.kafkaconnect.topicMappingTemplate: Confluent Kafkaトピック名を指定します。
6. 「作成および実行」をクリックします。「作成」をクリックすると、後で管理サービスの「概要」ページからReplicatを手動で起動できます。

管理サービスの概要ページに戻り、Replicatプロセスの表示、およびReplicatアクションにアクセスできます。

---

タイトルおよび著作権情報

Copyright ©2022,2025,

Oracle and/or its affiliates.