Before using ClickPipes, we relied on multiple tools to replicate MongoDB data into ClickHouse, many of which required constant maintenance or manual intervention. After switching to the MongoDB connector in ClickPipes, those issues disappeared: the initial setup was simple, and once configured, it has required no ongoing attention. Using materialized views makes data modeling flexible and easy to evolve.
Overall, ClickPipes has significantly reduced operational overhead and has worked great to replicate several terabytes of business data a day for analytical workloads.
insert
insert
update
delete
replace
add col
MongoDB CDC connector is now in Public Beta
Seamlessly replicate your MongoDB data to ClickHouse Cloud with just a few clicks. Get real-time analytics without the complexity or cost of external ETL tools. Learn more.
Advanced JSON Support
Seamlessly replicate MongoDB's rich document structures using ClickHouse's powerful native JSON data type. The connector preserves document structure and enables high-performance analytical queries on semi-structured data.
Real-time replication
Leverages MongoDB’s native Change Streams to capture document changes at scale, keeping TBs of data in sync with ClickHouse in real-time, with latencies as low as a few seconds.
Blazing-fast analytics
Integrates MongoDB with ClickHouse, enabling up to 100x faster analytics on your documents while continuing to run transactions reliably on MongoDB.
Simple
Easily replicate your MongoDB databases to ClickHouse Cloud in just a few clicks and few minutes!
No vendor lock-in
The MongoDB CDC connector is powered by PeerDB, an open-source project. Except for the UI, all components extend directly from PeerDB, ensuring no vendor lock-in.
What our customers are saying
Easily add your MongoDB source
MongoDB can be running anywhere - cloud or on-prem
Multiple replication modes: one-time load, CDC, or both

Customize incoming data
Table-level filtering
Fixed field extraction
JSON field-level filtering coming soon

Monitor your pipe
Track throughput (rows or GB ingested) and latency over time
Detailed table-level metrics
Built-in logging for full visibility

Edit pipe in-place
Add more tables in just a few clicks
Change replication settings, including data freshness
Blazing-fast resyncs
