Atlas Stream Processing の変更ログ

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

Atlas Administration APIを使用してストリーム プロセッサを編集することをサポートします。

Confluent でAWS PrivateLink をサポートします。

EventHub とAzure Private Link をサポートします。

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

ターゲット クラスターが 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 を使用して特定のリージョンでストリーム プロセシング インスタンスを作成できないバグを修正しました。