2026 リリース
25は2026のリリース
initialSyncメモリ処理の改善を統合します。
7は2026のリリース
Azureの
brazilsouthとaustraliaeast、eu-west-3AWSのus-east4、Google Cloud リージョンの のサポートを追加します。Azure Blob Storage 接続のプライベート ネットワークのサポートを追加します。詳しくは、「 Azure Blog Storage Private Link 接続を追加する 」を参照してください。
ストリーム テナントが見つからない場合に、誤ったHTTPステータス コードを返す問題を修正します。
S3 またはAWS Kinesis接続に対してAWS PrivateLink を有効にすると、Atlas UIにコスト警告が表示されます。
ソースまたは シンクがターゲットごとの統計をサポートしていない場合、ストリーム プロセッサ メトリクスUIでソース メッセージ消費および Sink メッセージ配信パネルを非表示にします。
パイプライン ビジュアル ビルダのKinesis Sink テンプレートの無効なフィールドを修正します。
Atlas Administration APIの 1
tierつのストリーム プロセッサの作成 エンドポイントに オプションを追加します。
28 4月2026リリース
並列処理を使用しない場合における
$lookupのレイテンシ統計修正を統合します。metricThresholdオブジェクトを追加し、従来の
thresholdオブジェクトを非推奨にすることで、後方互換性を維持しながらTerraformリソース作成の問題を修正します。
15 4月2026リリース
Google Cloud Pub/Sub を Sink としてサポートするようになりました。詳しくは、Google Cloud パブリック/サブスクライブ接続 を参照してください。
JSONエディターUIページの新しい Upload file ボタンを使用して、ローカル
.jsonファイルからプロセッサ定義を直接アップロードするためのサポートを追加します。
6 4月2026リリース
- シンクとしてのAzure Blog ストレージのサポートを追加します。詳しくは、Azure Blob Storage(
$emitステージ)およびAzure Blob Storage Connectionsを参照してください。
25 3 月2026リリース
サンプル、Apache Kafka、Atlas 接続のテスト アイコンをラベルの付いた TEST ボタンに置き換えます。
ストリーム プロセッサが参照クラスターの削除をブロックします。
Apache Kafka 接続レジストリで
PLAINとOIDCの間でApache Kafka接続認証を変更できるようにします。Apache Kafkaブートストラップサーバーのホスト名に追加の検証を追加します。
16 2 月2026リリース
プロジェクト レベルのストリーム監査をデフォルトで有効にし、Atlas UIの Database & Network Access > Security > Advanced ページから Streams Auditing トグルを削除します。監査ログが常に表示され、削除できなくなり、セキュリティとコンプライアンスの期待を満たすことができます。Atlas Stream Processing 監査の詳細については、Atlas Stream Processing のアクセスと監査 を参照してください。
接続レジストリで接続を表示すると、Atlas UI にリアルタイムステータス(
Ready、Pending、Failed、Deleting)が Atlas UIに追加されます。Atlas UIでStream プロセッサを作成する 際に、ソース オプションおよび Sink オプションとしてAWS Kinesis接続のサポートを追加します。
基礎の Atlas クラスターがまだプロビジョニングいる間に、ストリーム接続を早期に
Readyとしてマークする問題を修正します。ロール割り当てで
modifyStreamProcessorアクションが使用できない問題を修正しました。ストリーム プロセッサを開始、停止、削除する操作のエラー処理を改善します。
Azure Event Hub 接続の検証を改善し、有効な名前空間 ARM URI のみが受け入れられるようにします。
7 1 月2026リリース
2025 リリース
3 12 月2025リリース
ソース(
$sourceステージ)およびシンク( ステージ)としてAWS Kinesisのサポートを追加します。$emitストリーム プロセッサと宛先リージョンの両方のリージョン固有の料金を反映するようにデータ転送価格を更新します。さらに学ぶには、ストリーム プロセッサの価格を参照してください。
SP10SP30および 階層ストリーム プロセッサの価格を、レガシーのワーカーベース モデルからプロセッサごとの価格モデルに更新します。詳細については、「 ストリーム プロセッサの価格 」を参照してください。
29 10 月2025リリース
前のインスタンスモデルを Atlas Stream Processing ワークスペースに置き換えます。詳しくは、Stream Processing 階層を参照してください。
新しいストリーム プロセッサ階層を追加します。
SP2、SP5、SP50
1 10 月2025リリース
- Apache Kafka 接続の JWT 認証を使用した OIDC のサポートを追加します。
8 9 月2025リリース
- Atlas UIでストリーム プロセッサパイプラインを作成するためのサポートを追加します。
1 9 月2025リリース
- AWS S3プライベートリンク接続タイプのサポートを追加します。
27年 8 月2025リリース
接続ごとに接続テストを開始するために、 接続レジストリUIに Test Connection ボタンを追加します。
DataDog にエクスポートされるものを含む、
tenant_name、project_name、org_nameフィールドを Atlas Stream Processing メトリクスに追加します。lifetime cache hit/missステージの stats.operatorStats に$cachedLookup統計を追加します。
21年 8 月2025リリース
- Atlas DataDog 統合で
Stream Processor Stateメトリクスのサポートを追加しました。
19年 8 月2025リリース
$function演算子を追加し、Stream Processing パイプラインでJavaScript の実行を可能にします。 詳しくは、$function(Stream Processing) を参照してください。$cachedLookup演算子を追加します。これにより、$lookupの結果を特定の TTL でキャッシュし、更新頻度の低いデータのパフォーマンスを向上させることができます。詳細については、$cachedLookupをご覧ください。
18年 8 月2025リリース
$emitステージを追加し、null値を Kafka トピックに送信できるようにし、Kafka トピックのコンパクションをサポートします($emit.config.tombstoneWhen = booleanを使用)。詳細については、「$emit集計ステージ(Stream Processing)」を参照してください。
6年 8 月2025リリース
$sourceと$mergeのクロス Atlas プロジェクトのサポートを追加します。詳しくは、$merge(Stream Processing)参照の「Atlas クラスター間での変更ストリーム イベントの複製」セクションを参照してください。
31年 7 月2025リリース
- Atlas コレクションからの読み取り時に最初の同期をサポートするための
$sourceのサポートを追加します。詳しくは、 MongoDBコレクションの変更ストリーム を参照してください。
25年 7 月2025リリース
- Google Cloud に配置する Stream Processing ワークスペースのサポートを追加します。詳しくは、Google Cloud (GCP) Stream Processing リージョンを参照してください。
27 2025リリース
- コレクション内のドキュメントを削除できるようにする
$mergeのサポートを追加します。詳しくは、$merge(Stream Processing) を参照してください。
16 2025リリース
- DataDog メトリクスのサポートを追加しました。 詳細については、DataDog メトリクス を参照してください。
2 2025リリース
- Amazon Web Services S3 接続のサポートを追加します。
30 4月2025リリース
データを集計ためのセッションウィンドウを指定する新しい
$sessionWindowAtlas Stream Processingパイプライン集計ステージを追加します。これにより、入力ストリーム内のアクティビティの各「セッション」でパイプラインを実行できるようになります。詳しくは、$sessionWindow を参照してください。
26 3 月2025リリース
$externalFunction特定のAmazon Web Services Lambdaリソースでプロセスをトリガーする新しい Atlas Stream Processingパイプラインステージを追加します。詳細については、$externalFunction を参照してください。
12 3 月2025リリース
Atlas UIでの $ https 接続の作成をサポートします。
parallelismフィールドを$mergeに追加します。フィールドは、書込み (write) 操作を分散するスレッド数を指定することで、パフォーマンスを向上させます。出力メッセージ数、DLQ メッセージ数、 Kafkaラグ、変更ストリーム遅延 などの追加のアラートを作成できます。詳しくは、Atlas Stream Processing アラート を参照してください。
5 3 月2025リリース
ストリーム プロセッサで、引数なしで UUID BSON 型の値を返す createUUID 式をサポートします。
eventTimeに加えてprocessingTimeをサポートするウィンドウ演算子の新しい構成を追加します。詳細については、プロセシング時間を参照してください。ドキュメントのすべてのストリーミングメタデータを含むオブジェクトを返す $meta式を追加します。
演算子に
parseJsonStringsフィールドを追加し、$httpsAPI呼び出しから返されたJSON String を解析できるようにします。詳細については、$https を参照してください。
14 2 月2025リリース
Amazon Web Services MSK クラスター用のKafka Private Link 接続を追加できます。
AWS
us-east-2上で Stream Processing ワークスペースを配置できます。詳細については、Atlas Stream Processing リージョンをご覧ください。
20 1 月2025リリース
Atlas Stream Processing が評価するたびに、Stream Processing ワークスペースのシステム時間を返す $currentDate 式をサポートします。
埋め込みファイル署名(マジックバイト)を含むJSONドキュメントの読み取りをサポートします。
intervalより大きいhopSizeでWindowsのホスティングを構成できない問題を修正します。
14 1 月2025リリース
executionTimeSecsの統計情報をexecutionTimeMillisに変更します。この統計を表示するには、sp.processor.stats()コマンドを呼び出します。$emitApacheステージ(ストリーム プロセシング)のバッファリング期間を Kafkaから 1000 ミリ秒に変更します。
2024 リリース
10 12 月2024リリース
- Amazon Web Servicesで Confluent とのVPCピアリングをサポートします。
02 12 月2024リリース
Atlas Administration API を使用して、ストリーム プロセッサの編集をサポート。
Confluent で AWS PrivateLink をサポート。
EventHubs で Azure Private Link をサポート。
11 11 月2024リリース
- Apache Kafkaタイムアウトを 10 秒から 30 秒に増加させます。
23 10 月2024リリース
ターゲット クラスターが
REPAIRING状態にある場合は、常にプロセッサを再試行します。チェックポイント復元後に
partitionIdleTimeoutを修正します。冗長な統計にウォーターマークとウィンドウ情報を追加します。
Apache Kafkaへのメッセージを生成するための呼び出しは、プロデューサー キューがいっぱいになった場合でも、無期限にハングしないようにします。
11 10 月2024リリース
マルチトピックApache Kafkaソースの取り込みをサポートします。
コンシューマー グループのApache Kafka
offsetsをほぼリアルタイムで更新します。Apache Kafka $t 構成で と 設定をサポートします。
compression.typeacksコレクションレス $lookup構文をサポートします。
Atlas Stream Processing がApache Kafkaエラーを string に直列化する方法を標準化します。
ウィンドウパイプライン内で一意の を使用して $lookup
connectionNameを処理します。一時停止されたクラスター エラーを改善します。
28年 8 月2024リリース
Apache Kafka をソースとして使用するストリーム プロセッサは、
sp.processor.stats(). でパーティションごとのウォータマークを公開します。