機械翻訳について

Kafkaプラットフォームからのデータの取得

OCI GoldenGateを使用して、Kafkaプラットフォーム・ストリーミング・ソースからメッセージを抽出します。

概要

OCI GoldenGateを使用して、次のストリーミング・ソースからメッセージを取得できます:

• Apache Kafka
• OCIストリーミング
• スキーマ・レジストリの有無にかかわらず、Confluent Kafka
• Azure Event Hubs
• Amazon MSK

OCI GoldenGateは、Kafkaトピックまたはトピックからメッセージを読み取り、データをGoldenGate 証跡ファイルに書き込まれる論理変更レコードに変換します。 GoldenGate Replicatプロセスは、証跡ファイルの生成を使用して、RDBMS実装をサポートするためのデータを伝播できます。

タスク1: コンシューマ・プロパティの構成

1. 次のデシリアライザまたはコンバータのいずれかを使用して、Kafkaコンシューマ・プロパティ・ファイルを作成します。 ソースがスキーマ・レジストリとのConfluent Kafkaのトピックである場合は、Avroコンバータを使用できます。 その他のソースの場合は、必要に応じてJSONコンバータまたはデシリアライザを使用します:
   • Kafka JSONデシリアライザのコンシューマ・プロパティ:

     key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
     value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer

   • Kafka JSONコンバータのコンシューマ・プロパティ:

     key.converter=org.apache.kafka.connect.json.JsonConverter
     value.converter=org.apache.kafka.connect.json.JsonConverter

   • Kafka Avroコンバータのコンシューマ・プロパティ:

     key.converter=io.confluent.connect.avro.AvroConverter
     value.converter=io.confluent.connect.avro.AvroConverter

2. プロパティ・ファイルを保存し、そのロケーションをノートします。

タスク2: OCI GoldenGateリソースの作成

このタスクでは、新規リソースが存在しない場合の新規リソースの作成方法について説明します。 使用しているビッグ・データ・デプロイメントが使用可能な最新バージョンにアップグレードされていることを確認します。

1. ビッグ・データのOCI GoldenGateデプロイメントを作成します。
2. 接続の作成

   ノート:

   次の接続のいずれかを作成する場合は、必ず「高度なオプションを表示」をクリックし、コンシューマ・プロパティ・ファイルをアップロードしてください。
   • Apache KafkaまたはAmazon MSKの場合、「Kafka接続の作成」。
   • Confluent Kafka、「Confluent Kafka接続の作成」の場合。
   • Confluentスキーマ・レジストリの場合は、「Confluentスキーマ・レジストリ接続の作成」。
   • Azure Event Hubsの場合は、「Azure Event Hubs接続の作成」。
   • OCIストリーミングの場合、「OCIストリーミング接続の作成」。
3. ビッグ・データ・デプロイメントへの接続の割当て。

タスク3: 資格証明の作成

「抽出」を作成する前に、まず資格証明を作成する必要があります。

資格証明を作成するには:

1. 「デプロイメント」ページでBig Dataデプロイメントを選択します。
2. デプロイメントの詳細ページで、「コンソールの起動」をクリックします。
3. タスク2ステップ1でデプロイメントを作成したときに指定したユーザー名とパスワードを使用して、ビッグ・データ・デプロイメントにログインします。
4. ナビゲーション・メニューから「DB接続」を選択します。
5. 「構成」ページの「データベース」タブで、DB接続の追加 (プラス・アイコン)をクリックし、次のようにフォームに入力します:
   1. 「資格証明ドメイン」に、OracleGoldenGateと入力します。
   2. 「資格証明別名」には、kafkaと入力します。
   3. 「ユーザーID」には、kafka://と入力
   4. 「パスワード」および「パスワードの確認」には、パスワードを入力します。
   5. 「送信」をクリックします。

タスク4: 抽出の作成

1. 「管理サービスの概要」ページで、「抽出の追加」 (プラス・アイコン)をクリックします。
2. 次の値を含むExtractの追加:
   1. 抽出の「情報」ページで、次のようにフィールドに入力し、次をクリックします:
      • 「抽出」タイプで、「統合抽出」を選択します。
      • 「プロセス名」に、抽出の名前を入力します。
   2. 抽出オプション・ページで、次のようにフィールドに入力し、次をクリックします:
      • 「ドメイン」で、ドメインを選択します。
      • 「別名」で、デプロイメントに割り当てられている接続を選択します。
      • 「名前」に、2文字の名前を入力します。
   3. 「管理オプション」ページで、フィールドはそのままにして、「次」をクリックします。
   4. 「パラメータ・ファイル」ページで、次の手順を実行します:
      • 指定されたブートストラップ・サーバーのすべてのトピックをリスニングするには、表マッピングをTABLE TESTSCHEMA.*;のままにします。 表マッピングをTABLE TESTSCHEMA.<topic-name>;に設定して、指定したトピックから取得することもできます。
      • SOURCEDB USERIDALIASをSOURCEDB USERIDALIAS kafka DOMAIN OracleGoldenGateに更新します。
   5. 「Create and Run」をクリックします

「管理サービス」の「概要」ページに戻ります。このページでは、「抽出」プロセスの開始を確認し、イベント・メッセージを確認できます。

---

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

Copyright ©2022,2024,

Oracle and/or its affiliates.