2025年の Snowflake Connector for Kafka リリースノート¶

新機能¶

• コネクタは、フェールオーバー時にクライアントのリダイレクトを自動的に処理するようになりました。これにより、プライマリの展開変更後に手動でコネクタを再起動する必要がなくなりました。

• Snowpipe Streamingの自動フェールオーバーサポートを追加しました。

• トラブルシューティングを改善するために、スキーマ進化の詳細なログを追加しました。

• Snowflake Ingest SDKをバージョン4.4.0に更新しました。

動作の変更¶

• enable.streaming.channel.offset.migration プロパティのデフォルト値を false に変更しました。このプロパティは、Kafkaコネクタバージョン2.1.0または2.1.1から移行した後に、Snowflake Streamingチャネルが最初に使用されたときにのみ使用されていました。それらのバージョンによって作成されたチャネル（チャネル名にコネクタ名が含まれていました: [connectorName]_[topic]_[partition] ）から他のすべてのバージョンで使用されていたチャネル名形式（ [topic]_[partition] ）へのオフセットの移行を有効にしていました。

新機能¶

• snowflake.streaming.channel.name.include.connector.name プロパティを追加しました。true に設定した場合、これには、Snowpipe Streamingチャネル名（ [connectorName]_[topic]_[partition] ）のコネクタ名が含まれます。このプロパティを true に設定した場合、 enable.streaming.channel.offset.migration を false に設定する必要があります。これにより、Kafkaコネクタバージョン2.1.0および2.1.1のユーザーは、データを失うことなくアップグレードできます。

  警告

  snowflake.streaming.channel.name.include.connector.name を true に設定している、2.1.0および2.1.1以外のバージョンからアップグレードするユーザーは、データの重複が発生します。他のバージョンには、オフセットの移行ロジックはありません。

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

バグ修正¶

該当なし。

新機能¶

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

バグ修正¶

• OAuth URLsは、ドットとハイフンをサポートするようになりました。

動作の変更¶

該当なし

新機能¶

• Kafka用Snowflakeコネクタは、 Apache Iceberg™ テーブルでの timestamp 論理型を使用した long 型をサポートするようになりました。

  サポートする型の完全なリストについては、 Apache Iceberg™ テーブルのデータ型 をご参照ください。

バグ修正¶

該当なし。

動作の変更¶

該当なし

新機能¶

• Confluentバージョン7.9.2パッケージを使用します。

バグ修正¶

該当なし

動作の変更¶

該当なし

新機能¶

• JDBC バージョン3.24.2を使用します。

バグ修正¶

該当なし

動作の変更¶

該当なし

新機能¶

• SNOWPIPE_STREAMING インジェスチョンタイプの二重バッファーバージョンのサポートを削除しました。

  Snowflake.streaming.enable.single.buffer の設定は効果がありません。

バグ修正¶

• コネクタは、オフセットが欠落しているテーブル行をドロップしなくなりました。

• スキーマの進化中は、スキーマが変更されず、特定の単一の記録はドロップされなくなります。

動作の変更¶

• 二重バッファーを使用したSnowpipe Streamingは非推奨になりました。将来のリリースでは、シングルバッファーのみがサポートされます。

新機能および改善¶

• Kafkaバージョン3.9.0を使用するようにコネクタを更新しました。

• slf4j-apiバージョン2.0.17を使用するようにコネクタを更新しました。

• JDBC バージョン3.23.2をサポートします。

バグ修正¶

• snowflake-jdbcはｍ特定の状況における NullPointerException をスローしなくなりました。

動作の変更¶

該当なし

新機能¶

• :ref:` 浮動小数点数の -Infinity の値 <label-data_type_float>` の使用をサポートしています。

• Confluentバージョン7.9.0パッケージを使用するようにコネクタを更新しました。

• JDBC バージョン3.21.1をサポートします。

バグ修正¶

該当なし。

動作の変更¶

• Snowpipe Streamingのmax_client_lag のデフォルト値が 120秒 から 30秒 に変更されました。

新機能¶

該当なし

バグ修正¶

該当なし。

動作の変更¶

該当なし

新機能¶

• Kafka用のSnowflakeコネクタが、外部 OAuth 認証をサポートするようになりました。

• Kafka用Snowflakeコネクタが、Confluentバージョン7.8.0を使用するようになりました。

バグ修正¶

• スキーマの進化中にオフセットが連続しない場合にコネクタが IndexOutOfBoundException をスローしなくなりました。

• Snowpipeインジェスト方式では、 snowflake.topic2table.map パラメーターが複数のトピックを1つのテーブルにマッピングするように設定されている場合、コネクタはトピックのソルト hashCode をステージファイルのプレフィックスに追加して、ファイルの競合を回避し、指定されたすべてのトピックからデータを読み込みます。