Docs Menu
Docs Home
/
Atlas
/

Atlas Stream Processing の変更ログ

  • と のクロス Atlas$source$merge プロジェクトのサポートを追加します。詳しくは、 Atlas 接続 を参照してください。

  • AWS S3 接続のサポートを追加します。

  • $externalFunction特定のAmazon Web Services Lambdaリソースでプロセスをトリガーする新しい Atlas Stream Processingパイプラインステージを追加します。詳細については、$externalFunction を参照してください。

  • Atlas UIでの $ https 接続の作成をサポートします。

  • parallelismフィールドを$mergeに追加します。フィールドは、書込み (write) 操作を分散するスレッド数を指定することで、パフォーマンスを向上させます。

  • 出力メッセージ数、DLQ メッセージ数、 Kafkaラグ、変更ストリーム遅延 などの追加のアラートを作成できます。詳しくは、Atlas Stream Processing アラート を参照してください。

  • 引数を取らずに、ストリーム プロセッサで UUID BSON型の値を返す createUUID式をサポートします。

  • eventTime に加えて processingTime をサポートするウィンドウ演算子の新しい構成を追加します。詳細については、プロセシング時間を参照してください。

  • ドキュメントのすべてのストリーミングメタデータを含むオブジェクトを返す $meta式を追加します。

  • 演算子にparseJsonStringsフィールドを追加し、$https API呼び出しから返されたJSON String を解析できるようにします。詳細については、$https を参照してください。

  • Atlas Stream Processing が評価するたびにストリーム処理インスタンスのシステム時間を返す $currentDate式をサポートします。

  • 埋め込みファイル署名(マジックバイト)を含むJSONドキュメントの読み取りをサポートします。

  • interval より大きい hopSize でWindowsのホスティングを構成できない問題を修正します。

  • Amazon Web Services で Confluent との VPC ピアリングをサポートします。

  • Atlas Administration API を使用して、ストリーム プロセッサの編集をサポート。

  • Confluent で AWS PrivateLink をサポート。

  • EventHubs で Azure Private Link をサポート。

  • Apache Kafka のタイムアウトを 10 秒から 30 秒に増加させます。

  • ターゲット クラスターが REPAIRING 状態にある場合は、常にプロセッサを再試行します。

  • チェックポイント復元後に partitionIdleTimeout を修正します。

  • 冗長な統計にウォーターマークとウィンドウ情報を追加します。

  • Apache Kafkaへのメッセージを生成するための呼び出しは、プロデューサー キューがいっぱいになった場合でも、無期限にハングしないようにします。

項目一覧