Join us at MongoDB.local London on 7 May to unlock new possibilities for your data. Use WEB50 to save 50%.
MongoDB Branding Shape
Register now >

Atlas Stream Processing with AWS Kinesis Data Streams

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.

Related Content

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