2025 年 Snowflake Connector for Kafka 版本说明¶
本文包含 Snowflake Connector for Kafka 的版本说明，包括以下内容（如果适用）：
行为变更
新功能
面向客户的错误修复
Snowflake 对 Snowflake Connector for Kafka 更新使用语义版本控制。
有关文档，请参阅 Snowflake Connector for Kafka。
Version 3.3.0 (Aug 26, 2025)¶
行为变更¶
不适用
新功能¶
Snowflake Connector for Kafka 现支持在 |iceberg-tm| 表中使用 :code:
timestamp逻辑类型的 :code:long类型。有关受支持类型的完整列表，请参阅 Apache Iceberg™ 表的数据类型。
错误修复¶
Not applicable.
Version 3.2.4 (Jul 31, 2025)¶
仅限内部更新。
Version 3.2.3 (Jul 14, 2025)¶
仅限内部更新。
Version 3.2.2 (Jun 26, 2025)¶
行为变更¶
不适用
新功能¶
使用 Confluent 版本 7.9.2 软件包。
错误修复¶
不适用
Version 3.2.1 (Jun 2, 2025)¶
行为变更¶
不适用
新功能¶
使用 JDBC 版本 3.24.2。
错误修复¶
不适用
Version 3.2.0 (Apr 28, 2025)¶
行为变更¶
不适用
新功能¶
移除了对 SNOWPIPE_STREAMING 引入类型的双缓冲版本的支持。
设置
snowflake.streaming.enable.single.buffer没有任何效果。
错误修复¶
连接器将不再删除缺少偏移量的表行。
在架构演进过程中，架构更改时，某些单条记录不再被删除。
Version 3.1.3 (Apr 7, 2025)¶
行为变更¶
带双缓冲区的 Snowpipe Streaming 现已弃用。在未来的版本中，将仅支持单缓冲区。
新功能和改进¶
更新了连接器以使用 Kafka 版本 3.9.0。
更新了连接器以使用 slf4j-api 版本 2.0.17。
支持 JDBC 版本 3.23.2。
错误修复¶
snowflake-jdbc 在某些情况下不会再抛出 NullPointerException。
Version 3.1.2 (Mar 18, 2025)¶
行为变更¶
不适用
新功能¶
错误修复¶
Not applicable.
Version 3.1.1 (Feb 26, 2025)¶
行为变更¶
Snowpipe Streaming 中的 max_client_lag 默认值从
120 秒更改为了30 秒。
新功能¶
不适用
错误修复¶
Not applicable.
Version 3.1.0 (Jan 21, 2025)¶
重要
如果配置了 snowflake.topic2table.map 参数，Snowflake 建议使用此版本。如果您使用的是先前的 2.x、1.9.x 和 1.8.x 版本，强烈建议您升级连接器。
行为变更¶
不适用
新功能¶
The Snowflake Connector for Kafka now supports external OAuth authentication.
Snowflake Connector for Kafka 现在使用 Confluent 版本 7.8.0。
错误修复¶
在架构演化过程中偏移量不连续时，连接器不再引发
IndexOutOfBoundException。对于 Snowpipe 引入方法，当
snowflake.topic2table.map参数配置为将多个主题映射到单个表时，连接器会向暂存区文件前缀添加主题的 salthashCode，以避免文件冲突，并从所有指定主题加载数据。