This project has a example to how propagate data between Postgres and ElasticSearch using CDC Debezium

A hands-on example of building a real-time CDC pipeline from PostgreSQL to Elasticsearch using Debezium and Kafka Connect.

Debezium cdc data replication demo with Postgres source and Elasticsearch sink

Demo project using embedded Debezium to forward CDC changes from Postgres to Elasticsearch

this repo for change data capture (CDC) project using Postgres, Debezium, Kafka, Nifi and Elasticsearch

A high-performance distributed e-commerce ecosystem built on Spring Boot & Kafka. Implements manual CQRS with Polyglot Persistence (Postgres/Mongo/Elasticsearch), CDC via Debezium, Choreography Sagas for distributed transactions, and a self-healing Resilience Mesh.

ElasticSync is a real-time Change Data Capture (CDC) pipeline that streams Postgres database changes into Elasticsearch using Node.js, Kafka, and Debezium. Designed with an event-driven architecture, it ensures low-latency search, analytics, and fault-tolerant syncing between relational and NoSQL systems.