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 参数配置为将多个主题映射到单个表时,连接器会向暂存区文件前缀添加主题的 salt hashCode,以避免文件冲突,并从所有指定主题加载数据。

语言: 中文