Ingest data from MongoDB
MongoDB is a source-available, cross-platform, document-oriented database program.
Quick Start
Connect in minutes with SQL
Use CREATE SOURCE or CREATE TABLE to ingest data from MongoDB into RisingWave. No plugins, no middleware — just PostgreSQL-compatible SQL.
CREATE TABLE orders_rw (
order_id varchar PRIMARY KEY,
payload jsonb
) WITH (
connector='mongodb-cdc',
mongodb.url='mongodb://localhost:27017/?replicaSet=rs0',
collection.name='dev.*'
);For comprehensive configuration details, please refer to the MongoDB CDC connector documentation.
Capabilities
What you can do with RisingWave + MongoDB
Real-time Ingestion
Continuously stream data from MongoDB into RisingWave with sub-second latency. Process millions of events per second.
SQL Transformations
Join MongoDB data with other sources, apply windowing, aggregation, and filtering — all in standard SQL.
Materialized Views
Create incrementally maintained materialized views over MongoDB data. Always fresh, always queryable.
Multi-format Support
Supports Avro, JSON, Protobuf, CSV, and more. Compatible with Schema Registry for schema evolution.
Start streaming in minutes
Connect to MongoDB with just a few lines of SQL. No infrastructure to manage, no code to write.
