Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

Apache Kafka and Confluent Platform examples and demos

👾Scripts and samples to support Confluent Demos and Talks up until Oct '24. ⚠️ No longer maintained 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/

Examples for running Debezium (Configuration, Docker Compose files etc.)

大数据知识仓库涉及到数据仓库建模、实时计算、大数据、数据中台、系统设计、Java、算法等。

Example end to end data engineering project.

Database replication platform that leverages change data capture. Stream production data from databases to your data warehouse (Snowflake, BigQuery, Redshift, Databricks) in real-time.

Comprehensive guide to a couple of possible ways of synchronizing two states with Spring tools. Synchronization is shown by separating command and queries in a simple CQRS application.

A web UI for Debezium; Please log issues at https://issues.redhat.com/browse/DBZ.

Postgres change events (CDC) in Elixir

Replicate data from MySQL, Postgres and MongoDB to ClickHouse®

Replicates any database (CDC events) to Apache Iceberg (To Cloud Storage)

A full-stack .NET 6 Microservices build on Minimal APIs and C# 10

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

Fully reproducible, Dockerized, step-by-step, demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres. Detailed blog post published on Medium.

Bireme is an incremental synchronization tool for the Greenplum / HashData data warehouse

eCommerce application is a platform where customers can find products, shop around using a cart, check out the products and initiate payments. It is used for the didactic purpose only, as a support project for my training.

Real-time Data Warehouse with Apache Flink & Apache Kafka & Apache Hudi

SQL Server Change Stream sample using Debezium