This guide walks you through wiring Oracle AI Database 26ai (ATP) to OCI Streaming with Apache Kafka using the new “OCI Streaming with Apache Kafka” connection in OCI GoldenGate. We’ll capture change data from Oracle Autonomous AI Database and publish it to Kafka-compatible topics in OCI Managed Kafka —so downstream apps, analytics, and event-driven services can react in real time. 

On the streaming side, OCI provides fully managed Kafka clusters that are 100% API-compatible with open-source Kafka. You control clusters and brokers in your tenancy, create topics/partitions, and connect producers and consumers over private networking with standard Kafka security (SASL over SSL). We’ll lean on these primitives to keep the pipeline secure and low-latency.

On the database side, Oracle AI Database 26ai brings AI into the core of data management—vector search, agentic workflows, and more—announced at Oracle AI World on October 14, 2025. This blog focuses on operationalizing that innovation: streaming transactional changes from Oracle Autonomous AI Database into OCI Managed Kafka topics to power AI features, microservices, and analytics without batch delays.

By the end, you’ll have a production-ready pattern: GoldenGate Extract/Replicat publishing JSON events to OCI Kafka, with clear pointers on connection setup, security, topics, and validation.

 

Prerequisites

  • Scope & deployments in place
    • OCI GoldenGate: Oracle (source) deployment + Big Data (target) deployment are already provisioned and reachable.
    • Source DB: Oracle Autonomous AI Database 26ai is already created and will act as the source.
    • Kafka target: OCI Streaming with Apache Kafka (Managed Kafka) cluster is already created.
  • GoldenGate connections & capture readiness
    • OCI GoldenGate connection to the Autonomous AI Database is already created and tested .
    • Database is prepared for replication (e.g., required GoldenGate privileges and supplemental logging enabled).
    • A distribution path (or equivalent trail delivery) from Extract → Big Data Replicat is available or planned.
  • Kafka auth & access
    • For OCI Streaming with Apache Kafka, plan to authenticate producers with SASL/SCRAM (SCRAM-SHA-512) and configure required policies/ACLs and user credentials for the cluster. 
  • Networking & IAM
    • The OCI GoldenGate Big Data deployment (Replicat) has outbound access to the Kafka bootstrap and brokers (VCN route tables, NSGs/security lists, DNS).
    • OCI IAM policies support GoldenGate → Kafka connection creation and runtime access as per product docs. 
  • Topics & conventions
    • Required Kafka topics exist (or auto-create is enabled per cluster policy). Establish a naming convention such as <schema>.<table> to keep downstream consumers predictable. (OCI Managed Kafka is 100% API-compatible with open-source Kafka.)

Step-by-Step Setup

Step A: Create the OCI Streaming with Apache Kafka connection in GoldenGate

  1. In OCI Console → GoldenGate → your deployment → Connections → Create Connection.
  2. Choose Type “OCI Streaming with Apache Kafka”.
  3. Fill the bootstrap server addresses (from Streaming → Stream Pool → Kafka Connection Settings).
  4. Choose Security protocol (e.g. SASL_SSL) matching your cluster.
  5. In advanced options, input the auth token / user (the SASL username is given in Kafka connection settings) and possibly truststore / keystore if using TLS. (Oracle Documentation)
  6. You can use Vault secrets for secret management. (Oracle Documentation)
  7. Assign the connection to your OCI GoldenGate Big data deployment (so it is available for use).Validate that the connection can reach brokers (DNS, firewall) and authenticate.

Step B: Create connection for source OCI AI Database 26ai connection

1. Under Create conenction panel, enter Name as SourceATP and optionally, a description.

2. From the Compartment dropdown, select a compartment.

3. From the a Type dropdown, select Oracle AI Database.

4. For Database details, select Select database.

5. Select a Compartment from the dropdown, and then select source Oracle AI Database 26ai from the dropdown.

6. For Database username, enter ggadmin.

7. Select a Compartment from the dropdown, and then select a Database user password secret from the dropdown.

8. Click Create.

9. Assign the connection to your OCI GoldenGate for Oracle deployment.

 Unlock the GGADMIN user and enable supplemental logging for the source database

Oracle Autonomous Databases come with a GGADMIN user that is locked by default. The following steps guide you through how to unlock the GGADMIN user.

  1. From the Oracle Cloud Console navigation menu, click Oracle Database, and then select Autonomous Database.

Configure Extract (capture) from ADB

  1. In OCI GoldenGate for Oracle deployment UI (Administration / Data Replication side) → Add Extract.
  2. Select your ADB (source) connection (you may have already created a DB connection in GoldenGate).
  3. Choose a trail file prefix (e.g. et).
  4. Add schema / table rules (e.g. SCHEMA.*).
  5. Enable the extract and start it.

Make sure the extract is capturing DML/DDL as needed; monitor lag, errors.

Docs for quick reference:

  • SASL/SCRAM for OCI Managed Kafka (security and setup). (Oracle Docs)
  • GoldenGate → “OCI Streaming with Apache Kafka” connection (create target connection). (Oracle Docs)
  • Kafka concepts on OCI Managed Kafka (architecture & compatibility). (Oracle Docs)