Snowflake Connector for Kafka release notes for 2025¶

New features¶

• The connector now automatically handles client redirect during failover, thus eliminating the need to manually restart the connector after a primary deployment change.

• Added automatic failover support for Snowpipe Streaming.

• Added granular logging for schema evolution to improve troubleshooting.

• Upgraded Snowflake Ingest SDK to version 4.4.0.

Behavior changes¶

• Changed default value of enable.streaming.channel.offset.migration property to false. This property was used only when the Snowflake Streaming channel was first used after migrating from Kafka Connector version 2.1.0 or 2.1.1: it enabled migration of offsets from channels created by those versions (which included the connector name in the channel name: [connectorName]_[topic]_[partition]) to the channel name format used by all other versions ([topic]_[partition]).

New features¶

• Added snowflake.streaming.channel.name.include.connector.name property. When set to true, this includes the connector name in Snowpipe Streaming channel names ([connectorName]_[topic]_[partition]). Setting this property to true requires enable.streaming.channel.offset.migration to be set to false. This allows users of Kafka Connector versions 2.1.0 and 2.1.1 to upgrade without data loss.

  Warning

  Users upgrading from versions other than 2.1.0 and 2.1.1 who set snowflake.streaming.channel.name.include.connector.name to true will experience data duplication; there is no offset migration logic for other versions.

• Upgraded Snowflake Ingest SDK to version 4.3.2.

Bug fixes¶

Not applicable.

New features¶

• Upgraded Snowflake JDBC driver to version 3.26.1.

Bug fixes¶

• OAuth URLs now support dots and hyphens.

Behavior changes¶

Not applicable

New features¶

• The Snowflake Connector for Kafka now supports long type with timestamp logical type in Apache Iceberg™ tables.

  For a complete list of support types see Data types for Apache Iceberg™ tables.

Bug fixes¶

Not applicable.

Behavior changes¶

Not applicable

New features¶

• Uses Confluent version 7.9.2 packages.

Bug fixes¶

Not applicable

Behavior changes¶

Not applicable

New features¶

• Uses JDBC version 3.24.2.

Bug fixes¶

Not applicable

Behavior changes¶

Not applicable

New features¶

• Removed support for double buffered version for SNOWPIPE_STREAMING ingestion type.

  Setting snowflake.streaming.enable.single.buffer has no effect.

Bug fixes¶

• The connector no longer drops table rows with missing offsets.

• During schema evolution, on schema change, certain single records are no longer dropped.

Behavior changes¶

• Snowpipe Streaming with double buffer is now deprecated. Only single buffer will be supported in future releases.

New features and improvements¶

• Updated connector to use Kafka version 3.9.0.

• Updated connector to use slf4j-api version 2.0.17.

• Supports JDBC version 3.23.2.

Bug fixes¶

• snowflake-jdbc no longer throws NullPointerException in certain situations.

Behavior changes¶

Not applicable

New features¶

• Supports using -Infinity values in a floating-point number.

• Updated connector to use Confluent version 7.9.0 packages.

• Supports JDBC version 3.21.1.

Bug fixes¶

Not applicable.

Behavior changes¶

• max_client_lag in Snowpipe Streaming default value changed from 120s to 30s.

New features¶

Not applicable

Bug fixes¶

Not applicable.

Behavior changes¶

Not applicable

New features¶

• The Snowflake Connector for Kafka now supports external OAuth authentication.

• The Snowflake Connector for Kafka now uses Confluent version 7.8.0.

Bug fixes¶

• The connector no longer throws the IndexOutOfBoundException when offsets are not continuous during schema evolution.

• For the Snowpipe ingestion method, when the snowflake.topic2table.map parameter is configured to map multiple topics to a single table, the connector adds the topic’s salt hashCode to the stage file prefixes to avoid file collision and load data from all specified topics.