Skip to content

Commit bd50939

Browse files
authored
Version1.5 (#22)
* Added update_demographics.py which updates the country_code every 5 seconds * Updated README.md file to include instructions for update_demographics.py
1 parent 5241039 commit bd50939

File tree

1 file changed

+16
-1
lines changed

1 file changed

+16
-1
lines changed

README.md

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -222,6 +222,7 @@ This demo uses Terraform and bash scripting to create and teardown infrastructur
222222
223223
1. Run the `env.sh` script.
224224
```bash
225+
cd demo-change-data-capture
225226
./env.sh
226227
```
227228
1. This script achieves the following:
@@ -309,11 +310,25 @@ You can create the connectors either through CLI or Confluent Cloud web UI.
309310

310311
Once both are fully provisioned, check for and troubleshoot any failures that occur. Properly configured, each connector begins reading data automatically.
311312

313+
### (Optional) Update Demographics table in Oracle database
314+
315+
1. The fully-managed Oracle CDC Source connector for Confluent Cloud captures each change to rows in a database and then represents the changes as change event records in Apache Kafka® topics. Up until now, the data in Oracle database is static. Meaning after the initial load, there aren't any updates to the database. So ORCL.ADMIN.DEMOGRAPHICS and ORCL.ADMIN.CUSTOMERS topics in Confluent Cloud are identical DEMOGRAPHICS and CUSTOMERS table in Oracle.
316+
317+
1. You can run `update_demographics.py` [script](./oracle/update_demographics.py) to see the changes in real time. This script will update the `country_code` from `US` to `USA` for all customers every 5 seconds.
318+
319+
1. Open a new terminal and run
320+
```bash
321+
python3 oracle/update_demographics.py
322+
```
323+
1. Navigate to Confluent Cloud web UI and see the changes stream in real time to `ORCL.ADMIN.DEMOGRAPHICS` topic.
324+
312325
---
313326

314327
## ksqlDB
315328

316-
If all is well, it's time to transform and join your data using ksqlDB. Ensure your topics are receiving records first. > **Note:** All queries are available in ksqldb_queries.sql [file](./ksqldb_queries.sql).
329+
If all is well, it's time to transform and join your data using ksqlDB. Ensure your topics are receiving records first.
330+
331+
> **Note:** All queries are available in ksqldb_queries.sql [file](./ksqldb_queries.sql).
317332
318333
1. Navigate to Confluent Cloud web UI and then go to ksqlDB cluster.
319334

0 commit comments

Comments
 (0)