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

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

  • 動作の変更

  • 新機能

  • 顧客向けバグ修正

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

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

バージョン3.1.0(2025年1月21日)

重要

snowflake.topic2table.map パラメーターが設定されている場合は、Snowflakeではこのバージョンの使用を推奨しています。以前のバージョン2.x、1.9.x、1.8.xをお使いの場合は、コネクタのアップグレードを強くお勧めします。

動作の変更

該当なし

新機能

  • コネクタで外部OAuth認証に対応するようになります。

  • コネクタが更新され、Snowpipeのオフセットログが改善されています。

  • コネクタが更新され、Confluent 7.8.0をサポートするようになりました。

バグ修正

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

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