Check if configuration has isUnwrapped

memiiso · Jun 15, 2024 · 7a2be8c · 7a2be8c
1 parent b4234d6
commit 7a2be8c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergUtil.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergUtil.java
@@ -65,18 +65,18 @@ public static boolean configIncludesUnwrapSmt() {
 
   //@TestingOnly
   static boolean configIncludesUnwrapSmt(Config config) {
+    // first lets find the config value for debezium statements
     ConfigValue stms = config.getConfigValue("debezium.transforms");
     if (stms == null || stms.getValue() == null || stms.getValue().isEmpty() || stms.getValue().isBlank()){
       return false;
     }
 
     String[] stmsList = stms.getValue().split(",");
     final String regexVal = "^io\\.debezium\\..*transforms\\.ExtractNew.*State$";
-
+    // we have debezium statements configured! let's check if we have event flattening config is set.
     for (String stmName : stmsList) {
       ConfigValue stmVal = config.getConfigValue("debezium.transforms."+stmName+".type");
       if (stmVal != null && stmVal.getValue() != null && !stmVal.getValue().isEmpty() && !stmVal.getValue().isBlank() && stmVal.getValue().matches(regexVal)){
-        System.out.println(stmVal.getValue());
         return true;
       }
     }