A sample application demonstrating the Debezium Embedded Engine for capturing PostgreSQL database changes in real-time.
Trivial example showcasing how to use the Debezium Embedded Engine to capture changes from a PostgreSQL database. Created while prototyping features for TypeStream.
- Real-time change data capture (CDC) from PostgreSQL
- Debezium Embedded Engine integration
- Kotlin implementation
- PostgreSQL WAL (Write-Ahead Log) monitoring
- Ensure PostgreSQL is installed and running
- Run
./scripts/setup.shto initialize the database - Verify PostgreSQL is accessible at
localhost:5432 - Open the project in IntelliJ IDEA
By default, the application connects to PostgreSQL using your username with no password. Modify connection properties in src/main/kotlin/Main.kt if needed.
- Kotlin
- Debezium Embedded Engine
- PostgreSQL
- Gradle build system
MIT Copyright (c) Luca Pette