SNOW-1658905 Limit SnowflakeSinkConnectorConfig responsibilities (#925)

snowflakedb · Sep 18, 2024 · cea8f1f · cea8f1f
1 parent b07c9e4
commit cea8f1f
Show file tree

Hide file tree

Showing 12 changed files with 599 additions and 589 deletions.
diff --git a/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnector.java b/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnector.java
@@ -16,6 +16,7 @@
  */
 package com.snowflake.kafka.connector;
 
+import com.snowflake.kafka.connector.config.ConnectorConfigDefinition;
 import com.snowflake.kafka.connector.internal.KCLogger;
 import com.snowflake.kafka.connector.internal.SnowflakeConnectionService;
 import com.snowflake.kafka.connector.internal.SnowflakeConnectionServiceFactory;
@@ -192,7 +193,7 @@ public List<Map<String, String>> taskConfigs(final int maxTasks) {
   /** @return ConfigDef with original configuration properties */
   @Override
   public ConfigDef config() {
-    return SnowflakeSinkConnectorConfig.newConfigDef();
+    return ConnectorConfigDefinition.getConfig();
   }
 
   @Override