2025 リリース
6年 8 月2025リリース
と のクロス Atlas
$source$mergeプロジェクトのサポートを追加します。詳しくは、 Atlas 接続 を参照してください。
31年 7 月2025リリース
$sourceAtlas コレクションからの読み取り時に最初の同期をサポートするための のサポートを追加します。詳しくは、 「 MongoDBコレクションの変更ストリーム 」を参照してください。
25年 7 月2025リリース
Google Cloud に配置するストリーム プロセシング インスタンスのサポートを追加します。詳しくは、「 Google Cloud(GCP)Stream Processing リージョン 」を参照してください。
27 2025リリース
$mergeコレクション内のドキュメントを削除できるようにする のサポートを追加します。詳しくは、「 $merge(Stream Processing) 」を参照してください。
16 2025リリース
Datadog メトリクスのサポートを追加しました。詳細については、 Datadog メトリクス を参照してください。
2 2025リリース
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リリース
eventTimeに加えてprocessingTimeをサポートするウィンドウ演算子の新しい構成を追加します。詳細については、プロセシング時間を参照してください。ドキュメントのすべてのストリーミングメタデータを含むオブジェクトを返す $meta式を追加します。
演算子に
parseJsonStringsフィールドを追加し、$httpsAPI呼び出しから返されたJSON String を解析できるようにします。詳細については、$https を参照してください。
14 2 月2025リリース
Amazon Web Services MSK クラスター用のKafka Private Link 接続を追加できます。
Amazon Web Services
us-east-2に Atlas Stream Processing インスタンスを配置できます。 詳しくは、「Atlas Stream Processing リージョン」を参照してください。
20 1 月2025リリース
Atlas Stream Processing が評価するたびにストリーム処理インスタンスのシステム時間を返す $currentDate式をサポートします。
埋め込みファイル署名(マジックバイト)を含むJSONドキュメントの読み取りをサポートします。
intervalより大きいhopSizeでWindowsのホスティングを構成できない問題を修正します。
14 1 月2025リリース
executionTimeSecsの統計情報をexecutionTimeMillisに変更します。この統計を表示するには、sp.processor.stats()コマンドを呼び出します。$emitステージ(Stream Processing)のバッファリング時間を、Apache Kafka シンク向けに、1000 ミリ秒から 5 ミリ秒に変更します。
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()でパーティションごとのウォータマークを公開します。