新機能

Sink コネクタの クライアント側フィールドレベル暗号化 (CSFLE) のサポートを追加しました。これには、次の新しいMongoDB Connection 構成オプションが含まれます。

• csfle.enabled

• csfle.key.vault.namespace

• csfle.local.master.key

• csfle.schema.map

• csfle.bypass.query.analysis

Sink コネクタのステートレスフィールド復号化のサポートを追加しました。これには、次の新しいポストプロセッサ構成オプションが含まれます。

• field.value.transformer

• field.value.transformer.fields

セキュリティの脆弱性に対処するためにApache Kafka の依存関係を更新しました。

コネクターの動作を更新し、TLS v1.3 を優先するセキュアプロトコルとして明示的に指定し、v1.3 が使用できない場合は TLS v1.2 にフォールバックするようにしました。getSecureSslContext() メソッドは、TLS v1 で構成された SSLContext を返すようになりました。3または v1.2、どちらも使用できない場合は NoSuchAlgorithmException をスローします。

コネクタが変更ストリーム の再開に失敗した場合のログメッセージを WARN レベルから ERROR に変更しました。このようなエラーは障害メトリクスに反映されるようになりました。

セキュリティの脆弱性に対処するためにApache Kafka の依存関係をアップグレードしました。

変更ストリームシンクコネクタ構成を変更するために DeleteOneTombstoneBusinessKeyStrategy を追加しました。

change.stream.show.expanded.events変更ストリームソースコネクタ構成を追加しました。

Apache Kafkaバージョン{Kafka}で導入された問題を修正しましクラス。3.9

NullFieldValueRemover 事前に構築されたポストプロセッサを使用して、 出力内のすべての null 値フィールドを排除するためのサポートを追加しました。 詳しくは、「 事前に構築されたポストプロセッサ 」を参照してください。

タスクの再起動時にデータが再度コピーされるバグを修正しました。この修正の詳細については、Kafka-428 JIRA の問題 を参照してください。

Source Connector と Sink Connector のカスタム認証プロバイダー インターフェイスを追加しました。 この機能を使用すると、connector でカスタム実装クラスを記述して使用できます。 詳細については、「カスタム認証プロバイダ」のガイドを参照してください。

構成にシークレットが含まれており、 Providerフレームワークを使用している場合に、Source Connector と Sink Connector の構成を検証するときに発生する問題を修正しました。この修正の詳細については、Kafka-414 JIRA の問題 を参照してください。

mongo.errors.tolerance構成設定でdata構成値のサポートを追加しました。 mongo.errors.tolerance=dataを使用すると、Sink Connector はデータエラーのみを許容し、他のエラーに対しては失敗します。