> For the complete MongoDB documentation index, see www.mongodb.com/docs/llms.txt # Atlas Stream Processing Changelog ## 2026 Releases ### 8 October 2026 Release - Adds support for `asia-south1` in Google Cloud regions. ### 6 October 2026 Release - Adds nested schema inference to the `$iceberg` stage. To learn more, see [$iceberg.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-iceberg.md#std-label-atlas-sp-agg-iceberg) ### 23 September 2026 Release - Shows the outbound AWS (Amazon Web Services) account IDs that you use to set up private networking in the Atlas UI. - Fixes a bug where Streams Monitoring showed `0` for processor message metrics when no metrics data was available. Streams Monitoring now shows that no data is available instead of `0`. ### 10 September 2026 Release - Adds support for a cron schedule in the `$source` stage. To learn more, see [Cron Schedule.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-source.md#std-label-atlas-sp-agg-source-syntax-cron) ### 3 September 2026 Release - Adds support for vertical autoscaling. To learn more, see [Atlas Stream Processing Vertical Autoscaling.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/autoscaling.md#std-label-atlas-sp-autoscaling) - Adds support for `us-west1` in Google Cloud and `northeurope`, `eastasia`, and `southeastasia` in Azure (Microsoft Azure) regions. - Improves change stream source initial sync so that it can copy collections whose `_id` values span multiple BSON types, such as `ObjectId`, `string`, `numeric`, `date`, and `UUID`. To learn more, see [Configure Multi-Collection Initial Sync.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/multi-collection-initial-sync.md#std-label-atlas-sp-multi-collection-initial-sync) ### 1 September 2026 Release - Updates the `$iceberg` aggregation stage to write files to AWS (Amazon Web Services) S3 using the `s3://` scheme instead of the `s3a://` scheme, which increases compatibility with external query engines. To learn more, see [$iceberg.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-iceberg.md#std-label-atlas-sp-agg-iceberg) ### 27 August 2026 Release - Fixes a bug where Atlas Stream Processing did not support audit logs in `us-east-2`, `eu-west-3`, and `ap-northeast-2`. ### 19 August 2026 Release - Adds Private Link support for the [`$externalFunction`](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-externalfunction.md#mongodb-pipeline-pipe.-externalFunction) aggregation stage. To learn more, see [Add an AWS Lambda Private Link Connection.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/aws-lambda-private-connection.md#std-label-atlas-sp-pl-aws-lambda-add) ### 5 August 2026 Release - Adds support for parallelism in the [`$externalFunction`](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-externalfunction.md#mongodb-pipeline-pipe.-externalFunction) aggregation stage. ### 4 August 2026 Release - Adds the [`Project Stream Processing Manager`](https://www.mongodb.com/docs/atlas/reference/user-roles.md#mongodb-authrole-Project-Stream-Processing-Manager) role. To learn more, see [Project Roles.](https://www.mongodb.com/docs/atlas/reference/user-roles.md#std-label-project-roles) - Adds support for creating an AWS (Amazon Web Services) Confluent Enterprise cluster Private Link connection without a `dnsDomain` value. To learn more, see [Add a Kafka Private Link Connection.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/kafka-private-connection.md#std-label-atlas-sp-pl-kafka-add) - Adds a modal in the Atlas UI for checkpoint clearing when editing a stream processor. - Adds new activity feed events for Atlas Stream Processing. ### 14 July 2026 Release - Adds support for the [`$vectorSearch`](https://www.mongodb.com/docs/vector-search/query/aggregation-stages/vector-search-stage.md#mongodb-pipeline-pipe.-vectorSearch) pipeline stage. ### 9 July 2026 Release - Improves how Kafka source stream processors distribute processing across partitions during periods of heavy load, resulting in more even processing. - Adds stream processor CPU and memory usage to the Monitoring tab in the Atlas UI. To learn more, see [Monitor Stream Processor Workspaces in the Atlas UI.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/monitoring.md#std-label-atlas-sp-monitoring-ui) ### 30 June 2026 Release - Adds general availability support for writing to [Apache Iceberg](https://iceberg.apache.org/docs/latest/) tables using the `$iceberg` aggregation stage. To learn more, see [$iceberg.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-iceberg.md#std-label-atlas-sp-agg-iceberg) ### 23 June 2026 Release - Adds support for regional failover. To learn more, see [Failover Processors.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/architecture.md#std-label-atlas-sp-architecture-failover) ### 18 June 2026 Release - Overhauls the UI experience for creating and editing a stream processor. To learn more, see [Create a Stream Processor.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-stream-processor.md#std-label-atlas-sp-manage-processor-create) - Adds read-only access to the Edit Connection page for in-use connections from a connection registry entry. A banner indicates that you must stop processors using the connection before making any changes. Previously, you had to stop processors using the connection to view its details. To learn more, see [View Connections in the Connection Registry.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-connection-registry.md#std-label-atlas-sp-manage-connection-view) - Improves error messaging when creating a pipeline in the Atlas UI. ### 15 June 2026 Release - Adds support for multi-collection `initialSync`. To learn more, see [MongoDB Collection Change Stream.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-source.md#std-label-atlas-sp-agg-source-syntax-coll) - Adds an `addedParallelism` field to [`sp.processor.stats()`](https://www.mongodb.com/docs/manual/reference/method/sp.processor.stats.md#mongodb-method-sp.processor.stats) that reports the additional parallelism the stream processor has configured, calculated as the sum of `(parallelism - 1)` across every stage that sets a `parallelism` value greater than `1`. To learn more, see [View Statistics of a Stream Processor.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-stream-processor.md#std-label-atlas-sp-manage-processor-stats) ### 11 June 2026 Release - Adds the ability to change the tier of a stream processor in [`mongosh`](https://www.mongodb.com/docs/mongodb-shell.md#mongodb-binary-bin.mongosh). To learn more, see [`sp.processor.modify()`.](https://www.mongodb.com/docs/manual/reference/method/sp.processor.modify.md#mongodb-method-sp.processor.modify) ### 5 June 2026 Release - Adds the ability to change the tier of a stream processing workspace in the Atlas UI. - Adds direct links to the Visual Builder and JSON editor on empty stream processing workspace cards. - Fixes a bug where connection names could contain special characters other than `.`, `-`, `*`, and `_`. - Fixes a bug where the [Get One Stream Processor](https://www.mongodb.com/docs/api/doc/atlas-admin-api-v2/operation/operation-getgroupstreamprocessor) endpoint returns an HTTP 400 rather than a 404 when the stream processor doesn't exist. ### 25 May 2026 Release - Integrates an improvement to `initialSync` memory handling. ### 7 May 2026 Release - Adds support for the `brazilsouth` and `australiaeast` in Azure (Microsoft Azure), `eu-west-3` in AWS (Amazon Web Services), and `us-east4` in Google Cloud regions. - Adds support for private networking for Azure (Microsoft Azure) Blob Storage connections. To learn more, see [Add an Azure Blob Storage Private Link Connection.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/azure-blob-private-connection.md#std-label-atlas-sp-pl-azure-blob-add) - Fixes an issue that returned an incorrect HTTP status code when a workspace is not found. - Adds a display of the AWS PrivateLink cost for AWS Kinesis and S3 connections in the Atlas UI. - Fixes a UI issue where GCP Private Service Connect costs were not displaying correctly for Google Cloud workspaces. - Removes the source message consumption and sink message delivery panels in the stream processor metrics UI when the source or sink does not support per-target statistics. - Fixes an invalid field in the Kinesis sink template in the Pipeline Visual Builder. - Adds a `tier` option to the [Create One Stream Processor](https://www.mongodb.com/docs/api/doc/atlas-admin-api-v2/operation/operation-creategroupstreamprocessor) endpoint in the Atlas Administration API. ### 28 April 2026 Release - Integrates fixes for latency stats for `$lookup` when not using parallelism. - Adds the [metricThreshold](https://www.mongodb.com/docs/api/doc/atlas-admin-api-v2/operation/operation-creategroupalertconfig) object and deprecates the legacy `threshold` object to fix Terraform resource creation issues without breaking backward compatibility. ### 15 April 2026 Release - Adds support for Google Cloud Pub/Sub as a sink. To learn more, see [Google Cloud Pub/Sub Connections.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/add-sp-connection.md#std-label-atlas-sp-add-connection) - Adds support for uploading processor definitions directly from local `.json` files using a new Upload file button on the JSON Editor UI page. ### 6 April 2026 Release - Adds support for Azure (Microsoft Azure) Blob Storage as a sink. To learn more, see [Azure Blob Storage](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-emit.md#std-label-sp-emit-azure-blob) (`$emit` stage) and [Azure Blob Storage Connections.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/add-sp-connection.md#std-label-atlas-sp-add-connection) ### 25 March 2026 Release - Replaces the test icon with a labeled TEST button for Sample, [Apache Kafka](https://kafka.apache.org/), and Atlas connections. - Blocks deletion of clusters that stream processors still reference. - Allows changing [Apache Kafka](https://kafka.apache.org/) connection authentication between `PLAIN` and `OIDC` in the connection registry. - Adds additional validation for [Apache Kafka](https://kafka.apache.org/) bootstrap server hostnames. ### 16 February 2026 Release - Enables project-level streams auditing by default and removes the Streams Auditing toggle from the Database & Network Access > Security > Advanced page in the Atlas UI. Audit logs are now always-on and non-deletable to meet security and compliance expectations. To learn more about Atlas Stream Processing auditing, see [Atlas Stream Processing Access and Auditing.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/security.md#std-label-atlas-sp-security) - Adds a real-time status (`Ready`, `Pending`, `Failed`, `Deleting`) to the Atlas UI when you [view connections in the connection registry.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-connection-registry.md#std-label-atlas-sp-manage-connection-view) - Adds support for AWS Kinesis connections as source and sink options when you [Create a Stream Processor](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-stream-processor.md#std-label-atlas-sp-manage-processor-create) in the Atlas UI. - Adds support for the [Download Operational Logs for One Atlas Stream Processing Workspace](https://www.mongodb.com/docs/atlas/reference/api-resources-spec/v2/#operationdownloadGroupStreamOperationalLogs) endpoint in the Atlas Administration API to download operational logs for Atlas Stream Processing workspaces or stream processors. - Fixes an issue that prematurely marked streams connections as `Ready` while the underlying Atlas cluster was still provisioning. - Fixes an issue where the `modifyStreamProcessor` action was unavailable for role assignment. - Improves error handling for the operations to start, stop, and delete stream processors. - Improves validation for Azure Event Hub connections to ensure only valid Namespace ARM URIs are accepted. ### 7 January 2026 Release - Adds support for [Avro serializarion.](https://avro.apache.org/) - Adds support for integrations with [Confluent Schema Registry.](https://docs.confluent.io/platform/current/schema-registry/index.html#sr-for-product) - Allows writing over an HTTPS connection using [$https](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-https.md#std-label-atlas-sp-agg-https) as a final stage in a pipeline. ## 2025 Releases ### 3 December 2025 Release - Adds support for AWS (Amazon Web Services) Kinesis as a [source](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-source.md#std-label-atlas-sp-agg-source-syntax-kinesis) (`$source` stage) and as a [sink](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-emit.md#std-label-sp-emit-kinesis) (`$emit` stage). - Updates [data transfer pricing](https://www.mongodb.com/docs/atlas/billing/stream-processing-costs.md#std-label-atlas-sp-processor-billing) to reflect region-specific rates for both the stream processor and destination region. To learn more, see [stream processor pricing.](https://www.mongodb.com/docs/atlas/billing/stream-processing-costs.md#std-label-atlas-sp-processor-billing) - Updates pricing for `SP10` and `SP30` tier stream processors from the legacy worker-based model to the per-processor pricing model. To learn more, see [stream processor pricing.](https://www.mongodb.com/docs/atlas/billing/stream-processing-costs.md#std-label-atlas-sp-processor-billing) ### 29 October 2025 Release - Replaces the previous instance model with Atlas Stream Processing Workspaces. To learn more, see [Stream Processing Tiers.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/architecture.md#std-label-atlas-sp-architecture-tiers) - Adds new stream processor tiers: `SP2`, `SP5`, and `SP50`. ### 1 October 2025 Release - Adds support for OIDC with JWT Authentication for [Apache Kafka](https://kafka.apache.org/) connections. ### 8 September 2025 Release - Adds support to [create a stream processor pipeline](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-stream-processor.md#std-label-atlas-sp-manage-processor-create) in the Atlas UI. ### 1 September 2025 Release - Adds support for the AWS (Amazon Web Services) S3 (Simple Storage Service) private link connection type. ### 27 August 2025 Release - Adds the Test Connection button in the Connection Registry UI to initiate a connectivity test for each connection. - Adds the `tenant_name`, `project_name`, and `org_name` fields to Atlas Stream Processing metrics, including those exported to Datadog. - Adds `lifetime cache hit/miss` statistics to the [stats.operatorStats](https://www.mongodb.com/docs/atlas/atlas-stream-processing/manage-stream-processor.md#std-label-atlas-sp-manage-processor-stats) of the [`$cachedLookup`](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-cachedlookup.md#std-label-atlas-sp-agg-cachedlookup) stage. ### 21 August 2025 Release - Adds support for the `Stream Processor State` metric in the Atlas [Datadog integration.](https://www.mongodb.com/docs/atlas/tutorial/datadog-integration.md#std-label-datadog-integration) ### 19 August 2025 Release - Adds the `$function` operator, allowing for Javascript execution in stream processing pipelines. To learn more, see [`$function` (Stream Processing).](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-function.md#std-label-atlas-sp-agg-function) - Adds the `$cachedLookup` operator allowing for `$lookup` results to be cached for a specific TTL to improve the performance of slowly changing data. To learn more, see [`$cachedLookup`.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-cachedlookup.md#std-label-atlas-sp-agg-cachedlookup) ### 18 August 2025 Release - Adds the ability for the `$emit` stage to send `null` values to Kafka topics to support compacting Kafka Topics by using `$emit.config.tombstoneWhen = boolean`. To learn more, see [`$emit` Aggregation Stage (Stream Processing).](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-emit.md#std-label-streams-agg-pipeline-emit) ### 6 August 2025 Release - Adds support for Cross Atlas Project for `$source` and `$merge`. To learn more, see the [Replicate Change Stream Events Across Atlas Clusters](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-merge.md#std-label-atlas-sp-agg-merge-replicate-events) section in the `$merge` (Stream Processing) reference. ### 31 July 2025 Release - Adds support for `$source` to support Initial Sync when reading from Atlas collections. To learn more, see [MongoDB Collection Change Stream.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-source/#mongodb-collection-change-stream) ### 25 July 2025 Release - Adds support for Stream Processing Workspaces to deploy on Google Cloud. To learn more, see [Google Cloud (GCP) Stream Processing Regions.](https://www.mongodb.com/docs/atlas/reference/google-gcp/#std-label-gcp-stream-processing-regions) ### 27 June 2025 Release - Adds support for `$merge` to be able to delete documents in collections. To learn more, see [$merge (Stream Processing).](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-merge/#definition) ### 16 June 2025 Release - Adds support for Datadog Metrics. To learn more, see [Datadog Metrics.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/monitoring/#stream-processor-metrics-in-datadog) ### 2 June 2025 Release - Adds support for AWS (Amazon Web Services) S3 (Simple Storage Service) connections. ### 30 April 2025 Release - Adds a new [`$sessionWindow`](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-session.md#mongodb-pipeline-pipe.-sessionWindow) Atlas Stream Processing pipeline aggregation stage that specifies a session window for aggregation of data. This allow you to run a pipeline on each "session" of activity in an input stream. To learn more, see [$sessionWindow.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-session.md#std-label-atlas-sp-agg-session) - Supports [Azure-hosted Confluent Kafka clusters via Private Link connection.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/kafka-private-connection.md#std-label-atlas-sp-pl-kafka-add) ### 26 March 2025 Release - Adds a new [`$externalFunction`](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-externalfunction.md#mongodb-pipeline-pipe.-externalFunction) Atlas Stream Processing pipeline stage that triggers processes in a specific AWS Lambda resource. To learn more, see [$externalFunction.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-externalfunction.md#std-label-atlas-sp-agg-external-function) ### 12 March 2025 Release - Supports [creating $https connections](https://www.mongodb.com/docs/atlas/atlas-stream-processing/add-sp-connection.md#std-label-atlas-sp-add-connection) in the Atlas UI. - Adds the `parallelism` field to [$merge](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-merge.md#std-label-streams-agg-pipeline-merge). The field specifies the number of threads to which to distribute write operations, which improves performance. - Allow you to create additional alerts: Output Message Count, DLQ Message Count, Kafka Lag, and Change Stream Delay. To learn more, see [Atlas Stream Processing Alerts.](https://www.mongodb.com/docs/atlas/reference/alert-conditions.md#std-label-atlas-sp-alerts) ### 5 March 2025 Release - Supports the [createUUID](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-createuuid.md#std-label-atlas-sp-agg-createuuid) expression that takes no arguments and returns UUID BSON (Binary Javascript Object Notation) type values in Stream Processors. - Adds a new configuration for Window operators to support `processingTime` in addition to `eventTime`. To learn more, see [Processing Time.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/architecture.md#std-label-atlas-sp-processing-time) - Adds the [$meta](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-meta.md#std-label-atlas-sp-agg-meta) expression that returns an object containing all streaming metadata for a document. - Adds the `parseJsonStrings` field to the `$https` operator, allowing it to parse JSON Strings returned from an API call. To learn more, see [$https.](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-https.md#std-label-atlas-sp-agg-https) ### 14 February 2025 Release - Allows you to [add a Kafka Private Link Connection](https://www.mongodb.com/docs/atlas/atlas-stream-processing/kafka-private-connection.md#std-label-atlas-sp-pl-kafka-add) for AWS MSK clusters. - Allows you to deploy Stream Processing Workspaces on AWS `us-east-2`. To learn more, see [Atlas Stream Processing Regions.](https://www.mongodb.com/docs/atlas/atlas-stream-processing.md#std-label-atlas-sp-regions) ### 20 January 2025 Release - Supports the [$currentDate](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-currentdate.md#std-label-atlas-sp-agg-currentdate) expression that returns the system time of your stream processing workspace each time Atlas Stream Processing evaluates it. - Supports reading JSON documents with embedded file signatures (magic bytes). - Fixes an issue that prevented the configuration of hopping windows with `hopSize` greater than `interval`. ### 14 January 2025 Release - Changes the `executionTimeSecs` stat to `executionTimeMillis`. To view this stat, invoke the [`sp.processor.stats()`](https://www.mongodb.com/docs/manual/reference/method/sp.processor.stats.md#mongodb-method-sp.processor.stats) command. - Changes the buffering duration for [`$emit` Aggregation Stage (Stream Processing)](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-emit.md#std-label-streams-agg-pipeline-emit) to [Apache Kafka](https://kafka.apache.org/) sinks from 1000 milliseconds to five milliseconds. ## 2024 Releases ### 10 December 2024 Release - Supports VPC (Virtual Private Cloud) Peering with Confluent on AWS (Amazon Web Services). ### 02 December 2024 Release - Supports using the Atlas Administration API to edit stream processors. - Supports AWS PrivateLink with Confluent. - Supports Azure Private Link with EventHubs. ### 11 November 2024 Release - Increases [Apache Kafka](https://kafka.apache.org/) Timeout from 10 seconds to 30 seconds. ### 23 October 2024 Release - Always retries processors when the target cluster is in the `REPAIRING` state. - Fixes the `partitionIdleTimeout` after the checkpoint restore. - Adds more watermark and window information to verbose stats. - Ensures calls to produce messages to [Apache Kafka](https://kafka.apache.org/) don't hang indefinitely, even when the producer queue is full. ### 11 October 2024 Release - Supports ingesting multitopic [Apache Kafka](https://kafka.apache.org/) sources. - Updates [Apache Kafka](https://kafka.apache.org/) `offsets` for consumer groups to near-real time. - Supports the `compression.type` and `acks` settings in the [Apache Kafka](https://kafka.apache.org/) [$emit](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-emit.md#std-label-streams-agg-pipeline-emit) configuration. - Supports collectionless [$lookup](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-lookup.md#std-label-streams-agg-pipeline-lookup) syntax. - Standardizes the way Atlas Stream Processing serializes [Apache Kafka](https://kafka.apache.org/) errors into a string. - Increases the [$emit](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-emit.md#std-label-streams-agg-pipeline-emit) and [$merge](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-merge.md#std-label-streams-agg-pipeline-merge) dynamic expression limit to `1000`. - Handles [$lookup](https://www.mongodb.com/docs/atlas/atlas-stream-processing/sp-agg-lookup.md#std-label-streams-agg-pipeline-lookup) with unique `connectionName` inside window pipeline. - Improves paused cluster errors. ### 28 August 2024 Release - Supports converting from [`Binary`](https://www.mongodb.com/docs/manual/reference/mongodb-extended-json.md#mongodb-bsontype-Binary) data to various data types using [$convert](https://www.mongodb.com/docs/manual/reference/operator/aggregation/convert/). This allows you to transform Kafka headers into specific data types as needed. - Stream processors that use [Apache Kafka](https://kafka.apache.org/) as a source expose per-partition watermarks in [`sp.processor.stats()`.](https://www.mongodb.com/docs/manual/reference/method/sp.processor.stats.md#mongodb-method-sp.processor.stats) - Fixes a bug where users were unable to create stream processing workspaces in certain regions through the [API.](https://www.mongodb.com/docs/api/doc/atlas-admin-api-v2/operation/operation-creategroupstreamworkspace)