Skip to content

Commit

Permalink
SNOW-1658905 Extract ConnectorConfigDefinition from the main config c…
Browse files Browse the repository at this point in the history
…lass
  • Loading branch information
sfc-gh-mbobowski committed Sep 17, 2024
1 parent b07c9e4 commit db47ffa
Show file tree
Hide file tree
Showing 12 changed files with 598 additions and 589 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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
Expand Down
Loading

0 comments on commit db47ffa

Please sign in to comment.