Playground for Lakehouse (Iceberg, Hudi, Spark, Flink, Trino, DBT, Airflow, Kafka, Debezium CDC)

Event-driven architecture (Transactional outbox, Inbox, and Saga patterns) on the modern stack of Java technologies.

Ecommerce using event driven architecture, built using Kafka and Debezium as internal communication

A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.

Project demonstrates realtime index updates via change data capture

Near Realtime Database project with Quarkus and MongoDB debezium connector

Microservice with Functional Core, Imperative shell Architectural pattern

A experiment with transactional event oubox message routing based on data from Pulsar's built-in Debezium Postgres source connector

Debezium-cdc plugado no mysql para realizar stream das alterações em um tópico do kafka.

Mockstagram - Instagram clone web service project built on a microservices architecture.

Driven by curiosity, I created small an event-driven ecosystem using Kafka, Kotlin, and Go, with MySQL, MongoDB, and H2. It started as a simple Kotlin-based Customer Service, but grew into something much more.

Async service communication based on Outbox pattern using: Kotlin, Kafka, Debezium Kafka Connect, Postgres and docker.

Demo application using Ktor, Exposed ORM, and Debezium

A small playground for debezium-postgres-kafka