Customer 360 & Real-Time Risk Intelligence Platform  ·  View 07 of 20

CDC and Historical Batch Ingestion

Log-based change capture from core banking systems, the initial historical snapshot, and how both land in bronze and merge into slowly changing silver dimensions.

Editable source SVG draw.io All views
Sources
Sources
Core Banking DB
Oracle redo logs
Core Banking DB...
Card Master
DB2 journals
Card Master...
CRM
Salesforce bulk API
CRM...
Partner Files
SFTP, daily drops
Partner Files...
Capture
Capture
Debezium Connectors
Log based, no query
Debezium Connectors...
Initial Snapshot
Parallel, chunked
Initial Snapshot...
File Landing Zone
Checksum + manifest
File Landing Zone...
Orchestration
Orchestration
Airflow DAGs
Sensors, SLAs, retries
Airflow DAGs...
Arrival Check
Completeness, control totals
Arrival Check...
Land
Land
Bronze Change Log
Op, LSN, commit ts
Bronze Change Log...
Late & Out of Order
Watermark buffer
Late & Out of Order...
Apply
Apply
Merge Into Silver
Delta MERGE, idempotent
Merge Into Silver...
SCD Type 2 Build
Valid from / to
SCD Type 2 Build...
Reconciliation
Row counts vs source
Reconciliation...
Silver tables
Silver tables
Party & Account
Current + history
Party & Account...
Product Holdings
Product Holdings
Historical Backfill
10 years loaded
Historical Backfill...
hold on fail
hold on fail
backfill
backfill
on pass
on pass
restated
restated
CDC and Historical Batch Ingestion
CDC and Historical Batch Ingestion
External / third party
External / third party
Interface / broker
Interface / broker
Application we own
Application we own
Decision point
Decision point
Data store
Data store
failure / alternate
failure / alternate
batch
batch
synchronous
synchronous
Snapshot and stream share one topic so cut-over from history to CDC needs no manual switch.
Snapshot and stream share one topic so cut-over from history to CDC needs no manual switch.
v 1.0 · owner Data Integration · date 2026-08
v 1.0 · owner Data Integration · date 2026-08
Text is not SVG - cannot display

Capture approach

  • Log-based CDC only — no query-based polling against production databases
  • Snapshot and stream share one topic, so history-to-CDC cut-over needs no manual switch
  • 10 years of history loaded once, chunked and throttled to protect source systems

Correctness controls

  • Delta MERGE keyed on business key plus commit sequence makes reapplication idempotent
  • SCD Type 2 preserves point-in-time truth for risk and regulatory restatement
  • Row-count and control-total reconciliation against source before silver promotion

Late and out-of-order data

  • A watermark buffer holds late arrivals rather than discarding them
  • Restated records re-enter the merge and propagate to gold on the next build
  • Consumers of restated periods receive a notice through the catalog