2025 年 Snowflake Connector for Kafka 版本说明¶
本文包含 Snowflake Connector for Kafka 的版本说明,包括以下内容(如果适用):
行为变更
新功能
面向客户的错误修复
Snowflake 对 Snowflake Connector for Kafka 更新使用语义版本控制。
有关文档,请参阅 Snowflake Connector for Kafka。
版本 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
参数配置为将多个主题映射到单个表时,连接器会向暂存区文件前缀添加主题的 salthashCode
,以避免文件冲突,并从所有指定主题加载数据。