PR fixes

snowflakedb · Sep 19, 2024 · bbfe1a0 · bbfe1a0
1 parent 4de5cff
commit bbfe1a0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/snowflake/kafka/connector/config/ConnectorConfigDefinition.java b/src/main/java/com/snowflake/kafka/connector/config/ConnectorConfigDefinition.java
@@ -466,7 +466,7 @@ public static ConfigDef getConfig() {
             ICEBERG_ENABLED,
             ConfigDef.Type.BOOLEAN,
             ICEBERG_ENABLED_DEFAULT_VALUE,
-            ConfigDef.Importance.MEDIUM,
+            ConfigDef.Importance.HIGH,
             "When set to true the connector will ingest data into the Iceberg table. Check the"
                 + " official Snowflake documentation for the prerequisites.");
   }

diff --git a/src/main/java/com/snowflake/kafka/connector/config/IcebergConfigValidator.java b/src/main/java/com/snowflake/kafka/connector/config/IcebergConfigValidator.java
@@ -16,7 +16,7 @@ public class IcebergConfigValidator implements StreamingConfigValidator {
   private static final String NO_SCHEMATIZATION_ERROR_MESSAGE =
       "Ingestion to Iceberg table requires " + ENABLE_SCHEMATIZATION_CONFIG + " set to true";
   private static final String INCOMPATIBLE_INGESTION_METHOD =
-      "Ingestion to Iceberg table is supported only for " + SNOWPIPE_STREAMING;
+      "Ingestion to Iceberg table is supported only for Snowpipe Streaming";
 
   @Override
   public ImmutableMap<String, String> validate(Map<String, String> inputConfig) {