Snowflake Connector for Kafka release notes for 2024

This article contains the release notes for the Snowflake Connector for Kafka, including the following when applicable:

  • Behavior changes

  • New features

  • Customer-facing bug fixes

Snowflake uses semantic versioning for Snowflake Connector for Kafka updates.

Version 2.2.2 (May 07, 2024)

Bug fixes

  • Fixed an issue where the staged files are not cleaned up properly.

Version 2.2.1 (March 15, 2024)

New features and updates

  • Added offset verification logic to make sure there is no missing or duplicate data.

  • Added client provider overridden map for Snowpipe Streaming. The map uses comma-separated key value pairs as input.

  • Upgraded to the following versions:

    • JDBC version to 3.14.5.

    • kafka connect-api version to 3.7.0.

    • jackson-core and jackson-databind to 2.16.1

    • commons-compress to 1.26.0

Bug fixes

  • Cleaned up streaming ingest threads when SinkTask stop () is called.

Version 2.2.0 (February 06, 2024)

BCR (Behavior Change Release) changes

  • Preserved the old data type that goes into an ARRAY column for schematization.

New features and updates

  • Added support for AVRO logical types.

  • Implemented changes to prevent potential data duplication because of a new channel name format.

  • Implemented changes to preserve the old data type that goes into an ARRAY column for schematization.

  • Implemented changes to make schema evolution add columns idempotent.

  • Enabled the Ingest SDK MAX_CLIENT_LAG configuration in Kafka connector.

Bug fixes

  • Fixed schema evolution cases that could cause non-exactly once delivery.

  • Fixed issues with generating and building Java library.

  • Fixed an issue that the Kafka offset is not reset correctly.

Language: English