This repository contains example projects and demos around data streaming (e.g. with Apache Kafka), stream processing (Apache Flink), change data capture (Debezium), open table formats (Apache Iceberg), and more. The examples typically accompany blog posts on morling.dev.
| Example | Description | Blog Post |
|---|---|---|
| debezium-kafka-flink-sql-ingest | Demo of different connectors and formats for ingesting Debezium data change events into Flink SQL | A Deep Dive Into Ingesting Debezium Events From Kafka With Flink SQL |
| postgres-toast-backfill | Different approaches for backfilling unchanged TOAST columns in Debezum data change events for Postgres | Backfilling Postgres TOAST Columns in Debezium Data Change Events |
| postgres-replication-slots | Monitoring Postgres replication slots | Mastering Postgres Replication Slots: Preventing WAL Bloat and Other Production Issues |
| debezium-engine | How to use Debezium with its Postgres connector as a library in a Java application | - |
| transactional-cdc-processing | Demo for joining and aggregating two CDC change event streams with transactional consistency | - |
This code base is available under the Apache License, version 2.