fix topic2table issue

snowflakedb · Sep 30, 2019 · 8a6d2a2 · 8a6d2a2
1 parent 65b9909
commit 8a6d2a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkTask.java b/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkTask.java
@@ -82,7 +82,7 @@ public void start(final Map<String, String> parsedConfig)
     //generate topic to table map
     this.topic2table =
       config.containsKey(SnowflakeSinkConnectorConfig.TOPICS_TABLES_MAP)?
-        Utils.parseTopicToTableMap(SnowflakeSinkConnectorConfig.TOPICS_TABLES_MAP)
+        Utils.parseTopicToTableMap(config.get(SnowflakeSinkConnectorConfig.TOPICS_TABLES_MAP))
         : new HashMap<>();
 
     //enable jvm proxy