Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

OLake - Fastest Databases, Kafka & S3 Replication to Apache Iceberg with Table optimization (Called OLake Fusion). ⚡ Efficient, quick and scalable data ingestion for real-time analytics. Supported sources : Postgres, MongoDB, MySQL, Oracle, MSSql, DB2, Kafka, S3.

Database replication platform that leverages change data capture. Stream production data from databases to your data warehouse (Snowflake, BigQuery, Redshift, Databricks) in real-time.

Distributed Data Transfer Service for MySQL

This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)

StorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service

A scalable Netflix DBLog implementation for PostgreSQL

Open Source Cloud Native Ingestion engine

go-pq-cdc is lightweight and efficient Change Data Capture (CDC) system designed for PostgreSQL

Kuvasz-Streamer is a Postgres-to-Postgres data consolidation and change data capture project.

A Golang package that implements CDC chunkers with a generic interface

etl engine 轻量级 跨平台 流批一体ETL引擎 数据抽取-转换-装载 ETL engine lightweight cross platform batch flow integration ETL engine data extraction transformation loading

Near real time cloud native data pipeline in AWS (CDC+Sink). Hosts code for RedshiftSink. RDS to RedshiftSink Pipeline with masking and reloading support.

Microservices Golang Saga Orchestration - Use Case using Transactional Outbox + Change Data Capture with Debezium

Go application to capture inserts into PostgreSQL table and produce events to Apache Kafka using replication slot and WAL

PostgreSQL Logical Replication CDC Module for Streaming Database Changes with Golang

go-pq-cdc-elasticsearch streams documents from PostgreSql and writes to Elasticsearch index in near real-time.

Postgres Logical Replication plugin for benthos

Comprehensive and reproducible benchmarks for Go developers and architects.

A stateless app to read events from MySQL binlog and write on Kafka using the Transactional Outbox Pattern.