Principle:Risingwavelabs Risingwave CDC Source Streaming
| Knowledge Sources | |
|---|---|
| Domains | CDC, Connectors, Streaming |
| Last Updated | 2026-02-09 07:00 GMT |
Overview
Lifecycle management for CDC source streaming handlers, managing startup, event processing, and graceful shutdown of change data capture streams.
Description
CDC Source Streaming manages the lifecycle of individual CDC source handlers from initialization through event streaming to shutdown. Each handler manages a Debezium CDC engine instance, handles the gRPC communication with the RisingWave compute node, and manages the event conversion pipeline. The handler tracks active source registrations, coordinates engine startup and shutdown, and ensures proper cleanup of resources (threads, connections, channels) when sources are dropped. This lifecycle management is critical for reliable CDC operation in a distributed streaming database.
Usage
Apply this principle when modifying CDC source handler lifecycle management, adding new source handler types, or debugging source startup/shutdown issues.