December 9, 2025
What it is:
Atlas Stream Processing now supports AWS Kinesis Data Streams, enabling bidirectional streaming between Kinesis and MongoDB. You can read from Kinesis streams for near real-time processing, write processed data back to Kinesis for downstream AWS services, or build transformation pipelines that enrich Kinesis events with MongoDB data. Authentication uses IAM Assume Role, and PrivateLink endpoints are supported for secure network connectivity.
Who it's for:
This integration is built for teams running event-driven architectures on AWS who need to connect streaming data pipelines with MongoDB for operational queries, change data capture, or near real-time enrichment workflows. It's particularly valuable for developers working with IoT telemetry, clickstream analytics, or microservices architectures that require seamless integration between Kinesis and Atlas.
Why it matters:
Native Kinesis integration eliminates the need for custom connector code, ongoing maintenance, and complex infrastructure management. Teams can now build production-grade streaming pipelines between AWS and MongoDB using familiar aggregation syntax, reducing integration overhead and accelerating time to deployment for near real-time data architectures.
How to get started:
Check out the documentation below for detailed instructions on configuring your stream processing pipeline.
Docs
Atlas Stream Processing Connection Registry
Docs
Atlas Stream Processing $source Aggregation Stage
Docs
Atlas Stream Processing $emit Aggregation Stage
Web
Atlas Stream Processing webpage