Upcoming talk at Postgres MetroPlex Dallas — April 2026
What is CDC?
Change Data Capture (CDC) is a set of software design patterns used to determine and track the data that has changed so that action can be taken using the changed data.
Instead of traditional polling (which is slow and adds load to the database), CDC allows us to stream every INSERT, UPDATE, and DELETE as it happens, with sub-second latency.
Why Debezium?
Debezium is an open-source distributed platform for change data capture. It points at your databases, and your applications can start responding to all of the row-level changes other applications make to your databases.
Debezium is built on top of Apache Kafka and provides connectors for several databases, with PostgreSQL being one of the most robust.
Key Advantages:
- Low Latency: Changes are captured almost instantly.
- No Schema Changes: You don’t need to add
updated_atcolumns or triggers to your tables. - Reliability: Captures every change, even those that happen while your application is down.
How it Works with Postgres
PostgreSQL uses a mechanism called Logical Decoding to extract changes from the Write-Ahead Log (WAL). Debezium hooks into this log using a logical decoding plugin (like pgoutput), converts the binary log into a structured format (JSON or Avro), and pushes it to Kafka.
Data Flow Diagram
flowchart LR
subgraph DB ["PostgreSQL Server"]
WAL[(Write-Ahead Log)]
Plugin[Logical Decoding Plugin]
WAL --> Plugin
end
subgraph Streaming ["Streaming Layer"]
Debezium[Debezium Connector]
Kafka{{Apache Kafka}}
Debezium --> Kafka
end
Plugin -- Change Events --> Debezium
subgraph Consumers ["Downstream Systems"]
App[Search Index / ES]
Cache[Redis / Cache]
Analytics[Data Warehouse]
end
Kafka --> App
Kafka --> Cache
Kafka --> Analytics
style Kafka fill:#fff9c4,stroke:#fbc02d,stroke-width:2px
style DB fill:#e1f5fe,stroke:#01579b
What We’ll Cover in the Talk
In the upcoming presentation at Postgres MetroPlex Dallas, we will dive deep into:
- Configuring PostgreSQL for logical replication.
- Setting up Debezium using Docker and Kafka Connect.
- Handling Schema Evolutions without breaking downstream consumers.
- Real-world Use Cases: Cache invalidation, building search indexes, and microservices synchronization.
Stay tuned for more details and the full presentation slides after the event!