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.

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.

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

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