Atlas Stream Processing の変更ログ

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

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

hopSize が interval より大きいホッピングウィンドウを構成できない問題を修正します。

executionTimeSecs の統計を executionTimeMillis に変更します。この統計を表示するには、sp.processor.stats() コマンドを実行します。

$emit の Apache Kafka シンクへのバッファリング期間を 1000 ミリ秒から 5 ミリ秒に変更します。

VPC ピアリングを Confluent と AWS でサポート。

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

コレクションレス $lookup構文をサポートします。

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

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

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

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

$convertBinary を使用して、 データからさまざまなデータ型への変換をサポートします。これにより、必要に応じて Kafka ヘッダーを特定のデータ型に変換できます。

Apache Kafka を使用するストリーム プロセッサ ソースとして、sp.processor.stats() でパーティションごとのウォータマークを公開します。

ユーザーがAPI を使用して特定のリージョンでストリーム プロセシング インスタンスを作成できないバグを修正しました。