<!-- mobian-agent-page publisher="dailydev" canonical="https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl" -->

---
title: Fan-out from Postgres with Change Data Capture using...
description: A practical guide to implementing Change Data Capture (CDC) with Neon's serverless Postgres using Debezium Server and Upstash Redis Streams. Covers the...
canonical: https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl
twitter:card: summary_large_image
twitter:site: @dailydotdev
og:type: website
og:site_name: daily.dev
og:title: Fan-out from Postgres with Change Data Capture using Debezium and Upstash Redis | daily.dev
og:description: A practical guide to implementing Change Data Capture (CDC) with Neon's serverless Postgres using Debezium Server and Upstash Redis Streams. Covers the...
og:url: https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl
og:image: https://api.daily.dev/og/posts/LNF39I1tl.png
og:image:alt: Fan-out from Postgres with Change Data Capture using Debezium and Upstash Redis
og:image:width: 1200
og:image:height: 630
og:locale: en
---

> ## Documentation Index
> Fetch the complete documentation index at: https://daily.dev/llms.txt
> Use this file to discover all available pages before exploring further.

# Fan-out from Postgres with Change Data Capture using Debezium and Upstash Redis

**[Neon](https://daily.dev/sources/neontech)** · 8 min read · 0 upvotes · 0 comments

## Summary

A practical guide to implementing Change Data Capture (CDC) with Neon's serverless Postgres using Debezium Server and Upstash Redis Streams. Covers the dual-write problem and why it's unreliable, then walks through enabling Postgres logical replication on Neon, configuring Debezium Server with application.properties, provisioning an Upstash Redis instance as a sink, running Debezium in Docker, and consuming the resulting Redis stream events with a Node.js consumer group using XREADGROUP and XACK for at-least-once delivery semantics.

## Full article

daily.dev links to this article rather than hosting it. Read it at the original source: <https://neon.com/blog/fan-out-postgres-changes-using-debezium-and-upstash-redis>

## Similar posts on daily.dev

- [Implementing real-time change data capture with Debezium for Amazon Aurora PostgreSQL and Amazon RDS for PostgreSQL](https://daily.dev/posts/implementing-real-time-change-data-capture-with-debezium-for-amazon-aurora-postgresql-and-amazon-rds-wwimwgweo) · AWS Database Blog · 0 upvotes · 0 comments
- [Debezium in Production: PostgreSQL to Kafka to Iceberg CDC Patterns That Actually Work](https://daily.dev/posts/debezium-in-production-postgresql-to-kafka-to-iceberg-cdc-patterns-that-actually-work-43qqjunc0) · BigData Boutique blog · 3 upvotes · 0 comments
- [Running the Debezium Platform on AWS: PostgreSQL to Amazon Kinesis](https://daily.dev/posts/running-the-debezium-platform-on-aws-postgresql-to-amazon-kinesis-pyepodjcm) · Debezium · 4 upvotes · 0 comments
- [How We Pushed CDC into Postgres](https://daily.dev/posts/how-we-pushed-cdc-into-postgres-gk0os0oyc) · Hacker News · 1 upvotes · 0 comments
- [Real-Time CDC From PostgreSQL to Snowflake, Step by Step](https://daily.dev/posts/real-time-cdc-from-postgresql-to-snowflake-step-by-step-oxsso8ssp) · Snowflake Community · 0 upvotes · 0 comments

---

Tags: [#architecture](https://daily.dev/tags/architecture), [#postgresql](https://daily.dev/tags/postgresql), [#redis](https://daily.dev/tags/redis), [#debezium](https://daily.dev/tags/debezium), [#change-data-capture](https://daily.dev/tags/change-data-capture)

[View this post on daily.dev](https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl)

```json
{"@context":"https://schema.org","@graph":[{"@type":"Organization","@id":"https://daily.dev/#organization","name":"daily.dev","url":"https://daily.dev","logo":{"@type":"ImageObject","url":"https://daily.dev/apple-touch-icon.png","width":180,"height":180},"sameAs":["https://twitter.com/dailydotdev","https://github.com/dailydotdev","https://www.linkedin.com/company/daily-dev-ltd"]},{"@type":"WebSite","@id":"https://daily.dev/#website","url":"https://daily.dev","name":"daily.dev","publisher":{"@id":"https://daily.dev/#organization"},"potentialAction":{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https://daily.dev/search?q={search_term_string}"},"query-input":"required name=search_term_string"}}]}
{"@context":"https://schema.org","@type":"TechArticle","headline":"Fan-out from Postgres with Change Data Capture using Debezium and Upstash Redis","url":"https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl","mainEntityOfPage":{"@type":"WebPage","@id":"https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl"},"datePublished":"2026-07-09T06:57:49.584Z","dateModified":"2026-07-09T07:00:44.877Z","description":"A practical guide to implementing Change Data Capture (CDC) with Neon's serverless Postgres using Debezium Server and Upstash Redis Streams. Covers the...","image":"https://media.daily.dev/image/upload/f_auto,q_auto/v1/posts/a7951aa8e8965f170d84e99079a60bf5?_a=AQAEuop","thumbnailUrl":"https://media.daily.dev/image/upload/f_auto,q_auto/v1/posts/a7951aa8e8965f170d84e99079a60bf5?_a=AQAEuop","isAccessibleForFree":true,"articleSection":"Neon","inLanguage":"en","publisher":{"@type":"Organization","name":"daily.dev","url":"https://daily.dev","logo":{"@type":"ImageObject","url":"https://daily.dev/apple-touch-icon.png","width":180,"height":180}},"author":{"@type":"Organization","name":"Neon","logo":"https://media.daily.dev/image/upload/s--65EDghou--/f_auto/v1724339118/logos/neontech","url":"https://daily.dev/sources/neontech"},"commentCount":0,"discussionUrl":"https://daily.dev/posts/fan-out-from-postgres-with-change-data-capture-using-debezium-and-upstash-redis-lnf39i1tl","interactionStatistic":[{"@type":"InteractionCounter","interactionType":{"@type":"LikeAction"},"userInteractionCount":0},{"@type":"InteractionCounter","interactionType":{"@type":"CommentAction"},"userInteractionCount":0}],"keywords":"architecture,postgresql,redis,debezium,change-data-capture","timeRequired":"PT8M"}
{"@context":"https://schema.org","@type":"BreadcrumbList","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https://daily.dev"},{"@type":"ListItem","position":2,"name":"Neon","item":"https://daily.dev/sources/neontech"},{"@type":"ListItem","position":3,"name":"Fan-out from Postgres with Change Data Capture using Debezium and Upstash Redis"}]}
```

