Change Data Capture (CDC) source that captures and streams change events from various databases. Leverages on Debezium and supports MySQL, PostgreSQL, MongoDB, Oracle and SQL Server databases.

Data Pipeline for streaming changes from MySQL database to the PostgreSQL database in near real time

Using Debezium CDC Connectors (Postgresql, Mysql, MongoDB) with Apache Pulsar

Change Data Capture (CDC) Pipeline with Debezium, Kafka, MySQL, and PostgreSQL, Oracle

Real-time CDC pipeline from MySQL to PostgreSQL ODS using Debezium and Kafka

Heterogeneous database migration tool based on Debezium CDC, supporting Oracle, MySQL, and PostgreSQL

AMQ Streams CDC Demo - Change Data Capture with Debezium, Kafka, MySQL, and PostgreSQL on OpenShift

This project implements Change Data Capture (CDC) between MySQL and PostgreSQL using Debezium and Kafka.

**Short Description:** 🚀 **CDC Pipeline using Debezium, Kafka, and PostgreSQL** – A Proof of Concept (POC) demonstrating real-time Change Data Capture (CDC) from **MySQL** to **PostgreSQL** using **Debezium** and **Kafka Connect**.

Debezium CDC を使用して MySQL から PostgreSQL へリアルタイムデータ同期を行う Docker Compose 環境

A production-style demo showcasing Event Sourcing + CQRS with Kotlin/Spring Boot, Kafka, Debezium CDC, PostgreSQL, MySQL, Apache Camel K and Kubernetes.

Complete CDC flow between MySQL and PostgreSQL using Kafka and Debezium, with a random producer, a Python consumer, and auditing of delete events.

A complete Terraform-managed CDC pipeline on Aiven. Streams MySQL changes to PostgreSQL in real-time using Kafka Connect, Debezium, and JDBC Sink.

A real-time Change Data Capture (CDC) pipeline that streams data changes from MySQL to PostgreSQL using Debezium, Apache Kafka, and Kafka Connect.

Near-real-time CDC stack using Debezium + Kafka + Kafka Connect to stream MySQL changes into PostgreSQL with upsert/delete support—runs via Docker Compose and includes Kafka UI.

Built a containerized Change Data Capture (CDC) pipeline (MySQL → Kafka → PostgreSQL) using Debezium & Kafka Connect. Supported real-time replication, schema evolution, and table normalization with Docker Compose orchestration.

Debezium is a CDC tool that can stream changes from MySQL, MongoDB, and PostgreSQL into Kafka, using Kafka Connect. We use it here to capture MySQL DB change in realtime when we make change from application GUI

Real-Time Retail Data Pipeline with CDC An end-to-end data engineering project that captures real-time transactions from PostgreSQL and MySQL using Debezium (CDC), streams them via Kafka, performs stateful aggregations with Apache Spark Structured Streaming, and serves live analytics using Redis. Dockerized for easy deployment.

Real-time CDC pipeline that polls the USGS FDSN Event API for earthquakes in the past minute, upserts incoming events into MySQL, streams binlog changes through Debezium/Kafka into PostgreSQL, and visualizes live seismic metrics in Grafana dashboards.

A real-time CDC pipeline that polls the USGS FDSN Event API for earthquakes in the past minute, upserts incoming events into MySQL, streams binlog changes through Debezium/Kafka into PostgreSQL, and visualizes live seismic metrics in Grafana dashboards.