use enum

snowflakedb · Nov 14, 2024 · dcc2f0f · dcc2f0f
1 parent b03c0f6
commit dcc2f0f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProperties.java b/...main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProperties.java
@@ -21,6 +21,7 @@
 import static com.snowflake.kafka.connector.SnowflakeSinkConnectorConfig.SNOWPIPE_STREAMING_CLIENT_PROVIDER_OVERRIDE_MAP;
 import static com.snowflake.kafka.connector.SnowflakeSinkConnectorConfig.SNOWPIPE_STREAMING_MAX_CLIENT_LAG;
 import static com.snowflake.kafka.connector.SnowflakeSinkConnectorConfig.SNOWPIPE_STREAMING_MAX_MEMORY_LIMIT_IN_BYTES;
+import static net.snowflake.ingest.utils.ParameterProvider.ENABLE_ICEBERG_STREAMING;
 import static net.snowflake.ingest.utils.ParameterProvider.MAX_CHANNEL_SIZE_IN_BYTES;
 import static net.snowflake.ingest.utils.ParameterProvider.MAX_CLIENT_LAG;
 import static net.snowflake.ingest.utils.ParameterProvider.MAX_MEMORY_LIMIT_IN_BYTES;
@@ -91,7 +92,7 @@ public StreamingClientProperties(Map<String, String> connectorConfig) {
     // Override only if the streaming client properties are explicitly set in config
     this.parameterOverrides = new HashMap<>();
     if (isIcebergEnabled) {
-      parameterOverrides.put("enable_iceberg_streaming", "true");
+      parameterOverrides.put(ENABLE_ICEBERG_STREAMING, "true");
     }
     Optional<String> snowpipeStreamingMaxClientLag =
         Optional.ofNullable(connectorConfig.get(SNOWPIPE_STREAMING_MAX_CLIENT_LAG));