2026 リリース
6 4月2026リリース
シンクとして Azure Blog ストレージ のサポートを追加します。詳しくは、「Azure Blob Storage(
$emitステージ)」と「Azure Blob Storage 接続」を参照してください。
25 3 月2026リリース
テスト アイコンを、ラベルの付いたTESTボタン(サンプル、Apache Kafka、および Atlas 接続用)に置き換えます。
ストリーム プロセッサが参照クラスターの削除をブロックします。
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リリース
AWS Kinesisのサポートをソース(
$sourceステージ)として、またシンク($emitステージ)として追加します。ストリーム プロセッサと宛先リージョンの両方のリージョン固有の料金を反映するようにデータ転送価格を更新します。さらに学ぶには、ストリーム プロセッサの価格を参照してください。
SP10およびSP30階層ストリーム プロセッサの価格を、レガシーのワーカーベース モデルからプロセッサごとの価格モデルに更新します。詳細については、ストリーム プロセッサの価格を参照してください。
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リリース
AWS S3 接続のサポートを追加します。
30 4月2025リリース
データを集計ためのセッションウィンドウを指定する新しい
$sessionWindowAtlas Stream Processingパイプライン集計ステージを追加します。これにより、入力ストリーム内のアクティビティの各「セッション」でパイプラインを実行できるようになります。詳しくは、$sessionWindow を参照してください。Private Link 接続経由で Azure がホストする Confluent Kafkaクラスターをサポートします。
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リリース
$convert
Binaryを使用して、 データからさまざまなデータ型への変換をサポートします。これにより、必要に応じて Kafka ヘッダーを特定のデータ型に変換できます。Apache Kafka をソースとして使用するストリーム プロセッサは、
sp.processor.stats(). でパーティションごとのウォータマークを公開します。ユーザーが API を使用して特定のリージョンで Stream Processing ワークスペースを作成できなかったバグを修正しました。