Table of Contents

Debezium Data Pipeline

Real-Time CDC Pipeline with Go

A complete real-time data pipeline implementation using Debezium, Kafka, and Elasticsearch with a Go microservice.

Features

Change Data Capture from PostgreSQL
Event streaming through Kafka
Elasticsearch integration for search and analytics
RESTful API with Fiber framework
Domain-Driven Design architecture
Docker Compose deployment

Technologies Used

Go
Debezium
Apache Kafka
Elasticsearch
PostgreSQL
Docker