Change Data Capture: A RabbitMQ and Debezium Approach
summary
Shows a concrete CDC pipeline using Debezium server to tail Postgres transaction logs and publish events into RabbitMQ streams, with an inventory service inserting products every few seconds. Demo runs end to end: Debezium writes change events (with rich metadata) to a RabbitMQ queue named "product" and a downstream consumer logs them; queue count tracks the DB rows (demo hits about 32 queued messages), proving reliable capture instead of dual writes.
AI-written summary · about
chapters (11)
- 0:00Introduction
- 2:34What is CDC
- 8:04CDC pipeline components
- 9:53Debezium server
- 11:59RabbitMQ for CDC
- 13:46Demo setup
- 17:06Running inventory service
- 19:00RabbitMQ queue setup
- 19:45Debezium for CDC
- 20:30Downstream service
- 21:59Q&A
related talks
01h 09mOpen-source Change Data Capture With Debezium
41mChange Data Streaming Patterns in Distributed Systems
31mChange Data Capture for non relational databases
49mChange Data Capture Pipelines with Debezium and Kafka Streams
36mChange Data Streaming Patterns for Distributed Systems
30mChange Data Streaming Patterns in Distributed Systems
14mHow not(!) to build real-time apps
35mChange Data Capture: The Magic Wand We Forgot #bbuzz