Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Docs Menu

Atlas Stream Processing の変更ログ

  • initialSync メモリ処理の改善を統合します。
  • Azureの brazilsouthaustraliaeasteu-west-3 AWSの us-east4、Google Cloud リージョンの のサポートを追加します。

  • Azure Blob Storage 接続のプライベート ネットワークのサポートを追加します。詳しくは、「 Azure Blog Storage Private Link 接続を追加する 」を参照してください。

  • ストリーム テナントが見つからない場合に、誤ったHTTPステータス コードを返す問題を修正します。

  • S3 またはAWS Kinesis接続に対してAWS PrivateLink を有効にすると、Atlas UIにコスト警告が表示されます。

  • ソースまたは シンクがターゲットごとの統計をサポートしていない場合、ストリーム プロセッサ メトリクスUIでソース メッセージ消費および Sink メッセージ配信パネルを非表示にします。

  • パイプライン ビジュアル ビルダのKinesis Sink テンプレートの無効なフィールドを修正します。

  • 並列処理を使用しない場合における$lookupのレイテンシ統計修正を統合します。

  • metricThresholdオブジェクトを追加し、従来のthresholdオブジェクトを非推奨にすることで、後方互換性を維持しながらTerraformリソース作成の問題を修正します。

  • Google Cloud Pub/Sub を Sink としてサポートするようになりました。詳しくは、Google Cloud パブリック/サブスクライブ接続 を参照してください。

  • JSONエディターUIページの新しい Upload file ボタンを使用して、ローカル .json ファイルからプロセッサ定義を直接アップロードするためのサポートを追加します。

  • サンプル、Apache Kafka、Atlas 接続のテスト アイコンをラベルの付いた TEST ボタンに置き換えます。

  • ストリーム プロセッサが参照クラスターの削除をブロックします。

  • Apache Kafka 接続レジストリで PLAINOIDC の間でApache Kafka接続認証を変更できるようにします。

  • Apache Kafkaブートストラップサーバーのホスト名に追加の検証を追加します。

  • 前のインスタンスモデルを Atlas Stream Processing ワークスペースに置き換えます。詳しくは、Stream Processing 階層を参照してください。

  • 新しいストリーム プロセッサ階層を追加します。SP2SP5SP50

  • Apache Kafka 接続の JWT 認証を使用した OIDC のサポートを追加します。
  • AWS S3プライベートリンク接続タイプのサポートを追加します。
  • 接続ごとに接続テストを開始するために、 接続レジストリUIに Test Connection ボタンを追加します。

  • DataDog にエクスポートされるものを含む、tenant_nameproject_nameorg_name フィールドを Atlas Stream Processing メトリクスに追加します。

  • lifetime cache hit/missステージの stats.operatorStats に $cachedLookup統計を追加します。

  • Atlas DataDog 統合Stream Processor State メトリクスのサポートを追加しました。
  • $function 演算子を追加し、Stream Processing パイプラインでJavaScript の実行を可能にします。 詳しくは、$function(Stream Processing) を参照してください。

  • $cachedLookup 演算子を追加します。これにより、$lookup の結果を特定の TTL でキャッシュし、更新頻度の低いデータのパフォーマンスを向上させることができます。詳細については、$cachedLookup をご覧ください。

  • $emit ステージを追加し、null 値を Kafka トピックに送信できるようにし、Kafka トピックのコンパクションをサポートします($emit.config.tombstoneWhen = boolean を使用)。詳細については、「$emit集計ステージ(Stream Processing)」を参照してください。
  • コレクション内のドキュメントを削除できるようにする $merge のサポートを追加します。詳しくは、$merge(Stream Processing) を参照してください。
  • DataDog メトリクスのサポートを追加しました。 詳細については、DataDog メトリクス を参照してください。
  • Amazon Web Services 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 が評価するたびに、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へのメッセージを生成するための呼び出しは、プロデューサー キューがいっぱいになった場合でも、無期限にハングしないようにします。

  • マルチトピックApache Kafkaソースの取り込みをサポートします。

  • コンシューマー グループのApache Kafkaoffsets をほぼリアルタイムで更新します。

  • Apache Kafka $t 構成で と 設定をサポートします。compression.typeacks

  • Atlas Stream Processing がApache Kafkaエラーを string に直列化する方法を標準化します。

  • $merge $merge の動的式の制限を1000 に増やします。

  • ウィンドウパイプライン内で一意の を使用して $lookupconnectionName を処理します。

  • 一時停止されたクラスター エラーを改善します。