Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.

SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.

Flink CDC is a streaming data integration tool

Apache Kafka, Apache Flink and Confluent Platform examples and demos

Support agile DataOps Based on Flink, DataX and Flink-CDC, Chunjun with Web-UI

Distributed Stream and Batch Processing

MongoDB Kafka Connector

Low Cost, Simple and Scalable Way of Data Replication to Apache Iceberg/Cloud/Data Lake

TiDB connectors for Flink/Hive/Presto

The source code of the book "Microservices Patterns (Chris Richardson)" and the personal study note of Eventuate Tram Framework (The whole solution of transactional messaging for Spring Boot microservices).

Kafka ecosystem ... but step by step!

**Unofficial / Community** Kafka Connect MongoDB Sink Connector -> integrated 2019 into the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.

ORAcle database CDC (Change Data Capture)

Multi-hop declarative data pipelines

polardbx-cdc is a core component of PolarDB-X which is responsible for global binary log generation, publication and subscription.

Postgresql To Kinesis For Java

Microservice application with various Redis use-cases with RediSearch, RedisGraph and Streams. The data are synchronize between MySQL and Redis using Debezium as a CDC engine

Dameng Connector 是一个专门为达梦数据库(DM Database)设计的变更数据捕获(CDC)解决方案。该项目通过扩展 Debezium 和 Flink CDC，实现了对达梦数据库的实时数据变更监控、捕获和处理能力，为数据集成、数据同步、实时分析等场景提供强大支持。

A Kafka source connector capturing Scylla CDC changes