Debezium Iceberg Consumer

This project implements Debezium Server Iceberg consumer see Debezium Server. It enables real-time replication of Change Data Capture (CDC) events from any database to Iceberg tables. Without requiring Spark, Kafka or Streaming platform in between.

See the Documentation Page for more details.

Installation

• Requirements:
• JDK 21
• Maven

Building from source code

git clone https://github.com/memiiso/debezium-server-iceberg.git
cd debezium-server-iceberg
mvn -Passembly -Dmaven.test.skip package
# unzip and run the application
unzip debezium-server-iceberg-dist/target/debezium-server-iceberg-dist*.zip -d appdist
cd appdist/debezium-server-iceberg
mv conf/application.properties.example conf/application.properties
bash run.sh

Contributing

The Memiiso community welcomes anyone that wants to help out in any way, whether that includes reporting problems, helping with documentation, or contributing code changes to fix bugs, add tests, or implement new features. See contributing document for details.

Contributors