allow field name without topic qualifier

debezium · Sep 10, 2024 · f24c40d · f24c40d
1 parent 32cd663
commit f24c40d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/io/debezium/connector/jdbc/filter/FieldFilterFactory.java b/src/main/java/io/debezium/connector/jdbc/filter/FieldFilterFactory.java
@@ -32,6 +32,9 @@ private static FieldNameFilter createFilter(String fieldList, boolean include) {
                 if (parts.length == 2 && parts[0].equals(topicName) && parts[1].equals(fieldName)) {
                     return include;
                 }
+                if (parts.length == 1 && parts[0].equals(fieldName)) {
+                    return include;
+                }
             }
             return !include;
         };