Snowflake Sink Connector with Snowpipe Streaming

Kafka Connect Managed Connectors
1

Hi,

I tried to enable Snowpipe Streaming in the managed Snowflake Sink Connector by adding this option:

snowflake.ingestion.method="SNOWPIPE_STREAMING"

However, this is ignored and the connector still uses the old Snowpipe without streaming.

According to the Snowflake documentation, Snowpipe Streaming is available starting from 1.9.1 version of the connector, so the version available on Confluent Hub (1.9.2 at the moment) satisfies this requirement.

Could anyone help to investigate this issue?

My full connector configuration:

{
  "name": "SnowflakeSinkConnector_0",
  "config": {
    "topics": "my_topic",
    "input.data.format": "JSON",
    "input.key.format": "STRING",
    "connector.class": "SnowflakeSink",
    "name": "SnowflakeSinkConnector_0",
    "snowflake.ingestion.method": "SNOWPIPE_STREAMING",
    "kafka.auth.mode": "KAFKA_API_KEY",
    "kafka.api.key": "",
    "kafka.api.secret": "",
    "snowflake.url.name": "https://my_id.snowflakecomputing.com:443",
    "snowflake.user.name": "",
    "snowflake.private.key": "",
    "snowflake.database.name": "",
    "snowflake.schema.name": "public",
    "snowflake.topic2table.map": "my_topic:my_table",
    "snowflake.metadata.createtime": "true",
    "snowflake.metadata.topic": "true",
    "snowflake.metadata.offset.and.partition": "true",
    "snowflake.metadata.all": "true",
    "buffer.flush.time": "10",
    "tasks.max": "1"
  }
}```

Best Regards,
Tomasz