Enable auto create for dynamic routing (#112)

databricks · Oct 9, 2023 · d723d3e · d723d3e
1 parent bf82d60
commit d723d3e
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/IcebergWriterFactory.java b/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/IcebergWriterFactory.java
@@ -50,13 +50,13 @@ public RecordWriter createWriter(
     try {
       table = catalog.loadTable(identifier);
     } catch (NoSuchTableException nst) {
-      if (ignoreMissingTable) {
+      if (config.autoCreateEnabled()) {
+        table = autoCreateTable(tableName, sample);
+      } else if (ignoreMissingTable) {
         return new RecordWriter() {};
-      } else if (!config.autoCreateEnabled()) {
+      } else {
         throw nst;
       }
-
-      table = autoCreateTable(tableName, sample);
     }
 
     return new IcebergWriter(table, tableName, config);