Change Data Capture

Stream OLTP changes via WAL → Debezium → Kafka → downstream sinks.

MermaidData & Schema Mermaid syntax docs

Template previewMermaid

Rendering…

Make it your own.

flowchart LR
PG[(Postgres)] -->|WAL| Debe[Debezium connector]
Debe --> KT[(Kafka topic\norders.cdc)]
KT --> S1[Search indexer]
KT --> S2[Analytics warehouse]
KT --> S3[Cache invalidator]
KT --> S4[Audit log]
S1 --> ES[(OpenSearch)]
S2 --> WH[(Warehouse)]
S3 --> Redis[(Redis)]