Atlas Stream Processing の変更ログ

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

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

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

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

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

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

compression.typeacksApache Kafka $ 構成で と 設定をサポートします。

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

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

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

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

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

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

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

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