From 7e9350313dc3fd076e4ef8345b10b6c996f815e7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Bobowski?= <145468486+sfc-gh-mbobowski@users.noreply.github.com> Date: Thu, 19 Sep 2024 13:03:09 +0200 Subject: [PATCH] NO-SNOW Enable closing channels in parallel by default (#928) --- .../snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java b/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java index 10b29f064..e7c0907dd 100644 --- a/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java +++ b/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java @@ -123,7 +123,7 @@ public class SnowflakeSinkConnectorConfig { // Whether to close streaming channels in parallel. public static final String SNOWPIPE_STREAMING_CLOSE_CHANNELS_IN_PARALLEL = "snowflake.streaming.closeChannelsInParallel.enabled"; - public static final boolean SNOWPIPE_STREAMING_CLOSE_CHANNELS_IN_PARALLEL_DEFAULT = false; + public static final boolean SNOWPIPE_STREAMING_CLOSE_CHANNELS_IN_PARALLEL_DEFAULT = true; // This is the streaming max client lag which can be defined in config public static final String SNOWPIPE_STREAMING_ENABLE_SINGLE_BUFFER =