Snowflake Connector for Kafka release notes for 2025¶

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.

See Snowflake Connector for Kafka for documentation.

Version 3.3.0 (Aug 26, 2025)¶

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.

Version 3.2.4 (Jul 31, 2025)¶

Internal updates only.

Version 3.2.3 (Jul 14, 2025)¶

Internal updates only.

Version 3.2.2 (Jun 26, 2025)¶

Behavior changes¶

Not applicable

New features¶

Uses Confluent version 7.9.2 packages.

Bug fixes¶

Not applicable

Version 3.2.1 (Jun 2, 2025)¶

Behavior changes¶

Not applicable

New features¶

Uses JDBC version 3.24.2.

Bug fixes¶

Not applicable

Version 3.2.0 (Apr 28, 2025)¶

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.

Version 3.1.3 (Apr 7, 2025)¶

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.

Version 3.1.2 (Mar 18, 2025)¶

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.

Version 3.1.1 (Feb 26, 2025)¶

Behavior changes¶

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

New features¶

Not applicable

Bug fixes¶

Not applicable.

Version 3.1.0 (Jan 21, 2025)¶

Important

If the snowflake.topic2table.map parameter is configured, Snowflake recommends using this version. We strongly recommend upgrading the connector if you are on earlier versions 2.x, 1.9.x, and 1.8.x.

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.