Ingest real-time change data capture (CDC) streams from PostgreSQL, MySQL, SQL Server, and MongoDB into RisingWave — no Kafka required. Native CDC connectors with shared source support.
Change data capture (CDC) lets you replicate real-time data changes from operational databases into RisingWave for stream processing and analytics. RisingWave provides native CDC connectors for PostgreSQL, MySQL, SQL Server, and MongoDB — no Kafka, Debezium, or additional middleware required. CDC data flows directly from the source database to RisingWave with transactional consistency, shared source support for multi-table ingestion, and automatic checkpoint recovery.
You can also use event streaming systems like Apache Kafka, Pulsar, or Kinesis to stream changes from MySQL, PostgreSQL, and SQL Server to RisingWave. In this case, you will need an additional CDC tool to stream the changes from the database and specify the corresponding formats when ingesting the streams into RisingWave. RisingWave documentation does not provide instructions about this approach.