※ 本記事は、Shrinidhi Kulkarniによる”Real-Time Data Replication from Oracle AI Database 26ai to OCI Streaming with Apache Kafka using OCI GoldenGate“を翻訳したものです。

2025年12月3日

このガイドでは、OCI GoldenGateの新しい「OCI Streaming with Apache Kafka」接続を使用して、Apache Kafkaを使用したOracle AI Database 26ai (ATP)からOCI Streamingへの接続手順について説明します。Oracle Autonomous AI Databaseから変更データを取得し、OCI Managed KafkaのKafka互換トピックに公開します。これにより、ダウンストリーム・アプリケーション、分析、およびイベントドリブン・サービスがリアルタイムで対応できるようになります。

ストリーミング側では、OCIは、オープンソースのKafkaと100% API互換のフルマネージドのKafkaクラスタを提供します。テナンシのクラスタおよびブローカを制御し、トピック/パーティションを作成し、標準のKafkaセキュリティ(SASL over SSL)を使用してプライベート・ネットワーキングを介してプロデューサおよびコンシューマを接続します。パイプラインを安全かつ低レイテンシに保つために、これらのプリミティブを活用します。

データベース側では、Oracle AI Database 26aiは、2025年10月14日にOracle AI Worldで発表された、ベクトル検索、エージェント・ワークフローなどのデータ管理の中核にAIを導入しています。このブログでは、そのイノベーションの運用に焦点を当てています。Oracle Autonomous AI DatabaseからOCI Managed Kafkaのトピックへのトランザクションの変更をストリーミングし、AI機能、マイクロサービス、分析をバッチ遅延なく強化します。

GoldenGate Extract/ReplicatがJSONイベントをOCI Kafkaに公開し、接続設定、セキュリティ、トピックおよび検証に関する明確なポインタを使用します。

前提条件

  • スコープとデプロイメントの状態
    • OCI GoldenGate: Oracle(ソース)デプロイメントとビッグ・データ(ターゲット)デプロイメントはすでにプロビジョニングされ、到達可能です。
    • ソースDB: Oracle Autonomous AI Database 26aiはすでに作成されており、ソースとして機能します。
    • Kafkaターゲット: Apache Kafka (Managed Kafka)クラスタを使用したOCIストリーミングはすでに作成されています。
  • GoldenGate接続および取得の準備
    • Autonomous AI DatabaseへのOCI GoldenGate接続はすでに作成およびテストされています。
    • データベースはレプリケーション用に準備されています(たとえば、必要なGoldenGate権限およびサプリメンタル・ロギングが有効になっています)。
    • Extract → ビッグ・データReplicatからの分散パス(または同等の証跡配信)が使用可能または計画されています。
  • Kafka認証およびアクセス
    • Apache Kafkaを使用したOCIストリーミングの場合、SASL/SCRAM (SCRAM-SHA-512)でプロデューサを認証し、クラスタに必要なポリシー/ACLおよびユーザー資格証明を構成することを計画します。
  • ネットワーキングおよびIAM
    • OCI GoldenGate Big Dataデプロイメント(Replicat)には、Kafkaブートストラップおよびブローカ(VCNルート表、NSG/セキュリティ・リスト、DNS)へのアウトバウンド・アクセスがあります。
    • OCI IAMポリシーは、製品ドキュメントに従って、GoldenGate → Kafka接続の作成およびランタイム・アクセスをサポートします。
  • トピックと表記規則
    • 必要なKafkaトピックが存在します(または、クラスタ・ポリシーごとに自動作成が有効になります)。「<schema>.<table>」などの命名規則を確立して、ダウンストリーム・コンシューマを予測可能にします。(OCI Managed Kafkaは、オープンソースのKafkaと100%のAPI互換です。)

ステップバイステップの設定

ステップA: Apache Kafka接続を使用したOCIストリーミングをGoldenGateに作成

  1. OCIコンソール → GoldenGate → デプロイメント → 接続 → 接続の作成
  2. 「OCI Streaming with Apache Kafka」タイプを選択
  3. ブートストラップ・サーバー・アドレスを入力します(「ストリーミング」 → 「ストリーム・プール」 → 「Kafka接続設定」)。
  4. クラスタに一致するセキュリティ・プロトコル(SASL_SSLなど)を選択
  5. 拡張オプションで、認証トークン/ユーザー(SASLユーザー名はKafka接続設定で指定)を入力し、TLSを使用している場合はトラストストア/キーストアを入力します。(Oracleドキュメント)
  6. Vaultシークレットをシークレット管理に使用できます。 (Oracleドキュメント)
  7. OCI GoldenGate Big Dataデプロイメントに接続を割り当てます(これにより、使用できます)。接続がブローカ(DNS、ファイアウォール)に到達できることを確認し、認証します。

ステップB: ソースOCI AI Database 26ai接続の接続の作成

  1. 「Create conenction」パネルで、「Name」にSourceATPと入力し、オプションで説明を入力します。
  2. 「Compartment」ドロップダウンから、compartmentを選択します。
  3. 「Type」ドロップダウンから、「Oracle AI Database」を選択します。
  4. 「Database details」で、「Select database」を選択します。
  5. ドロップダウンから「Compartment」を選択し、ドロップダウンからソース「Oracle AI Database 26aifrom」を選択します。
  6. 「Database username」に「ggadmin」と入力します。
  7. ドロップダウンから「Compartment」を選択し、ドロップダウンから「a Database user password secret」を選択します。
  8. 「Create」をクリックします。
  9. Oracleデプロイメント用にOCI GoldenGateに接続を割り当てます。

GGADMINユーザーのロックを解除し、ソース・データベースのサプリメンタル・ロギングを有効にします。

Oracle Autonomous Databasesには、デフォルトでロックされているGGADMINユーザーが付属しています。次のステップでは、GGADMINユーザーのロックを解除する方法について説明します。

  1. Oracle Cloudコンソールのナビゲーション・メニューから、「Oracle Database」、「Autonomous Database」の順に選択します。

ADBからのExtract (取得)の構成

  1. OCI GoldenGate for Oracle deployment UI(管理/データ・レプリケーション側) → Extractの追加
  2. ADB (ソース)接続を選択します(GoldenGateにDB接続がすでに作成されている可能性があります)。
  3. 証跡ファイルの接頭辞を選択します(例: et)。
  4. スキーマ/表ルールを追加します(例: SCHEMA.*)。
  5. 抽出を有効にして起動します。

必要に応じて、ExtractがDML/DDLを取得していることを確認します。遅延とエラーを監視します。

クイック・リファレンスのドキュメント: