Principle:Risingwavelabs Risingwave CDC PostgreSQL Streaming
| Knowledge Sources | |
|---|---|
| Domains | CDC, PostgreSQL, Streaming |
| Last Updated | 2026-02-09 07:00 GMT |
Overview
PostgreSQL-specific CDC streaming implementation using logical replication protocol and pgoutput message decoding.
Description
CDC PostgreSQL Streaming implements the PostgreSQL-specific change data capture mechanism using the logical replication protocol. It includes a pgoutput message decoder that parses the PostgreSQL logical replication stream messages (BEGIN, RELATION, INSERT, UPDATE, DELETE, COMMIT, TRUNCATE, ORIGIN, and TYPE messages), and a streaming change event source that manages the replication connection, slot management, and LSN (Log Sequence Number) tracking. The implementation patches upstream Debezium components to support RisingWave-specific requirements such as recovery-only snapshots and custom offset management.
Usage
Apply this principle when working with PostgreSQL CDC sources, debugging replication stream issues, or extending the pgoutput message handling.