Replicate data from ATP to Kafka
Learn to configure OCI GoldenGate to replicate data from Autonomous Transaction Processing to Apache Kafka.
Overview
Using OCI GoldenGate, you can replicate data from an Autonomous Database to a Big Data target, like Apache Kafka. This quickstart demonstrates how to set up an OCI GoldenGate deployment, source and target connections, and replication processes.
Before you begin
To successfully complete this quickstart, you must have the following:
- A VCN with port 9092 (or another port used for the bootstrap server) open in the Ingress rules.
- A source Autonomous Transaction Processing instance
- A target Apache Kafka node
Environment set up: Autonomous Transaction Processing
If you don't already have a source database set up for replication, you
can follow these steps to load a sample schema to use for this quickstart. This
quickstart uses Autonomous Transaction Processing for the source database.
To set up the source Autonomous Database:
- Download and unzip the sample database schema.
- In the Oracle Cloud console, select your Autonomous Transaction Processing (ATP) instance from the Autonomous Databases page to view its details and access Database Actions.
- Unlock the GGADMIN user:
- Click Database actions, then click Database Users.
- Locate GGADMIN and then click its ellipsis menu (three dots) and select Edit.
- In the Edit User panel, enter the GGADMIN password, confirm the password, and then deselect Account is Locked.
- Click Apply Changes.
- Load the source sample schema and data:
- Enable supplemental logging:
Task 1: Create the OCI GoldenGate resources
This quickstart example requires deployments and connections for both
the source and target.
- Create an Oracle deployment for the source Autonomous Transaction Processing instance.
- Create a Big Data deployment for the target Apache Kafka node.
- Create a connection for the source Autonomous Transaction Processing instance.
- Create a connection for the target Kafka node.
- (Optional) If your Big Data deployment doesn't have a public endpoint, then create a connection to GoldenGate, and then assign this connection to the source Oracle deployment.
- Assign the ATP connection to the source Oracle deployment.
- Assign the Kafka connection to the target Big Data deployment.
Task 2: Add the Extract
- On the Deployments page, select the source Autonomous Transaction Processing deployment.
- On the deployment details page, click Launch Console.
- Log in with the source deployment's administrator username and password.
- Add transaction information.
- Add an Extract.
Task 3: Add and run the Distribution Path
- If using GoldenGate credential store, create a user for the Distribution Path in the target Big Data deployment, otherwise skip to Step 3.
- In the source ATP GoldenGate deployment console, add a Path Connection
for the user created in Step 1.
- In the source ATP deployment console, add a Distribution Path with the following
values:
- In the target Big Data deployment console, review the Receiver Path created as a result of the Distribution Path.
- In the target Big Data deployment console, click Receiver Service.
- Review the path details. This path was created as a result of the Distribution Path created in the previous step.
Task 4: Add the Replicat
You return to the Replicats page, where you can
review the Replicat details.