2024年の Snowflake Connector for Kafka リリースノート

この記事には、 Snowflake Connector for Kafka のリリースノートが含まれています。また、該当する場合は以下が含まれます。

  • 動作の変更

  • 新機能

  • 顧客向けバグ修正

Snowflake は、 Snowflake Connector for Kafka の更新にセマンティックバージョニングを使用します。

ドキュメントについては、 Kafka用のSnowflakeコネクタ。 をご参照ください。

バージョン2.4.1(2024年9月19日)

新機能および更新

  • Snowflake Ingest Java SDK をバージョン2.2.2にアップグレードしました。

バグ修正

  • スキーマ化に関する問題を修正しました。

バージョン2.4.0(2024年8月15日)

新機能および更新

  • Snowflake Ingest Java SDK をバージョン2.2.0にアップグレードしました。このバージョンには、ストリームおよび動的テーブルで change_tracking が有効になっている場合に発生する可能性のある重大な問題の修正が含まれています。

  • Snowflake JDBC ドライバーをバージョン3.14.5からバージョン3.18.0にアップグレードしました。

  • トラブルシューティングの体験を向上させるために、さまざまなコンポーネントにおけるログ体験を改善しました。

  • チャネル再開のロジックを改善しました。

注釈

すべてのSnowpipe Streamingの使用において、SnowflakeはKafkaコネクタのバージョン2.4.0以降の使用を推奨します。

バグ修正

  • 既知の脆弱性を含む依存関係を更新しました。

バージョン2.3.0(2024年7月10日)

新機能および更新

  • Snowpipe Streamingチャネルを並列で閉じるサポートを追加し、リバランシングにかかる時間を大幅に短縮しました。

  • コネクタによってメッセージがプッシュされた時刻を表す新しい SnowflakeConnectorPushTime プロパティをメタデータに追加しました。

バグ修正

  • 既知の脆弱性を含む依存関係を更新しました。

バージョン2.2.2(2024年5月7日)

バグ修正

  • ステージングされたファイルが正しくクリーンアップされない問題を修正しました。

バージョン2.2.1(2024年3月15日)

新機能および更新

  • データの欠落や重複がないことを確認するためのオフセット検証ロジックを追加しました。

  • Snowpipe Streaming用のクライアントプロバイダー上書きマップを追加しました。マップはカンマ区切りのキー値ペアを入力として使用します。

  • 以下のバージョンにアップグレードしました。

    • JDBC バージョンを3.14.5に。

    • kafka connect-apiのバージョンを3.7.0に。

    • jackson-coreおよびjackson-databindを2.16.1に。

    • commons-compressを1.26.0に。

バグ修正

  • SinkTask stop () が呼び出されたときのストリーミングインジェストスレッドをクリーンアップしました。

バージョン2.2.0(2024年2月6日)

BCR (動作変更リリース)の変更

  • スキーマ化のために ARRAY 列に入る古いデータ型を保持しました。

新機能および更新

  • AVRO 論理型のサポートを追加しました。

  • 新しいチャネル名形式によるデータの重複を防ぐための変更を実装しました。

  • スキーマ化のために ARRAY 列に入る古いデータ型を保持するための変更を実装しました。

  • スキーマ進化による列の追加をべき等とする変更を実装しました。

  • KafkaコネクタのIngest SDK MAX_CLIENT_LAG 構成を有効にしました。

バグ修正

  • スキーマの進化によって、正確に1回限りの配信がされない場合があったのを修正しました。

  • Javaライブラリの生成と構築に関する問題を修正しました。

  • Kafkaオフセットが正しくリセットされない問題を修正しました。