xataio/pgstream

Health v2 · maintenance only

Adoption not part of the score

1195 stars · 84 forks observed · 2026-10-03

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

pgstream is an open-source change data capture (CDC) tool and Go library that replicates PostgreSQL data, including DDL/schema changes, to targets such as PostgreSQL, Elasticsearch/OpenSearch, webhooks, or Kafka. It also supports initial and on-demand snapshots and column-level value transformations for anonymizing data in flight.

Use cases

• replicate postgres to elasticsearch including schema changes
• stream postgres changes to another database with ddl support
• set up change data capture for postgresql
• anonymize data while replicating postgres
• take an initial snapshot of a postgres database
• sync postgres tables to opensearch
• send postgres change events to webhooks
• replicate postgres to kafka with schema-based partitioning

When to choose

• you need Postgres CDC that also propagates DDL/schema changes, which most CDC tools ignore
• you want to keep Elasticsearch or OpenSearch in sync with Postgres
• you need to mask or anonymize column values during replication
• you want a lightweight, modular pipeline that only requires Postgres and is extensible with custom targets

When to avoid

• your source database is not PostgreSQL
• you need a fully managed replication service with a GUI
• you only need simple one-off backups rather than change streaming
• you require targets other than Postgres, Elasticsearch/OpenSearch, webhooks, or Kafka without writing custom code

Facets

cli-tool · maturity active

database etl streaming search-engine webhook cli databases privacy developer-tools go self-hosted cli cdc postgres-replication ddl-replication logical-replication elasticsearch-indexing opensearch data-anonymization snapshots kafka change-data-capture data-engineering search linux macos docker

Member repositories

For agents

markdown · JSON · MCP: product_card(name="xataio/pgstream")