2024 年 Snowflake Connector for Kafka 版本说明

本文包含 Snowflake Connector for Kafka 的版本说明,包括以下内容(如果适用):

  • 行为变更

  • 新功能

  • 面向客户的错误修复

Snowflake 对 Snowflake Connector for Kafka 更新使用语义版本控制。

版本 2.2.2(2024 年 5 月 7 日)

错误修复

  • 修复了暂存文件未正确清理的问题。

版本 2.2.1(2024 年 3 月 15 日)

新功能和更新

  • 添加了偏移验证逻辑,以确保没有丢失或重复的数据。

  • 为 Snowpipe Streaming 添加了客户端提供商覆盖映射。该映射使用逗号分隔的键值对作为输入。

  • 升级到了以下版本:

    • JDBC 版本升级到 3.14.5。

    • kafka connect-api 版本升级到 3.7.0。

    • jackson-core 和 jackson-databind 版本升级到 2.16.1

    • commons-compress 版本升级到 1.26.0

错误修复

  • 清理了调用 SinkTask stop () 时的流式引入线程。

版本 2.2.0(2024 年 2 月 6 日)

BCR (行为变更版本)变更

  • 保留了进入 ARRAY 列的旧数据类型,以便进行自动格式演化。

新功能和更新

  • 添加了对 AVRO 逻辑类型的支持。

  • 实施了变更,以防止由于新的通道名称格式而可能导致的数据重复。

  • 实施了变更,保留进入 ARRAY 列的旧数据类型,以便进行自动格式演化。

  • 实施了变更,使架构演化添加列具有幂等性。

  • 在 Kafka Connector 中启用了 Ingest SDK MAX_CLIENT_LAG 配置。

错误修复

  • 修复了可能导致非精确一次投递的架构演化情况。

  • 修复了生成和构建 Java 库时出现的问题。

  • 修复了 Kafka 偏移未正确重置的问题。

语言: 中文