Apache Flink · FLK-10
CDC & lake sinks — Debezium changelog to Iceberg, commit on checkpoint, schema evolution
From your world. loading your lakehouse: a CDC feed from an operational database landing as an upserted Iceberg table your dbt models read
Run it locally
uv run de start FLK-10
uv run de test