change-data-capture

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

An extensible distributed system for reliable nearline data streaming at scale

SymmetricDS is database replication and file synchronization software that is platform independent, web enabled, and database agnostic. It is designed to make bi-directional data replication fast, easy, and resilient. It scales to a large number of nodes and works in near real-time across WAN and LAN networks.

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

Event-Driven Architecture for a microservices-based system with a clean architecture + Domain Driven Design (DDD) + CQRS pattern + Saga pattern + Outbox pattern + CDC.

Debezium Server runtime for standalone execution of Debezium connectors. Please log issues at https://github.com/debezium/dbz/issues.

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

Kubernetes/OpenShift operator for Debezium Server. Please log issues at https://github.com/debezium/dbz/issues.

此项目主要应用于数据中台或数据平台的数据总线，支持直接实时监听MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra等数据库的数据变更。

Example projects and demos around data streaming , stream processing, change data capture, and more.

A Kafka source connector capturing Scylla CDC changes

An incubating Debezium CDC connector for Vitess. Please log issues at https://github.com/debezium/dbz/issues.

⚾ Streaming left joins in Kafka for change data capture

Datastax CDC for Apache Cassandra

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

Microservices Java/Spring-Boot Saga Orchestration - Use Case using Transactional Outbox + Change Data Capture with Debezium

Denormalize and Index MySQL database with ElasticSearch and Kafka

A Spring-based implementation of the transactional outbox pattern.