Test consumer without event flattening

memiiso · Jun 15, 2024 · b91706c · b91706c
1 parent 5fee360
commit b91706c
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...zium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java b/...zium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java
@@ -324,12 +324,12 @@ private Schema icebergSchema() {
 //// NOTE! because while for insert events only `after` field is populated for delete events only `before` field is populated!
 //// NOTE! because of this inconsistency we cannot set either of the filed as key field!
 ////        // NOTE: events re not unwrapped, align schema with event schema, so then we can scan event and key schemas synchronously
-        ObjectNode nestedKeySchema = mapper.createObjectNode();
-        nestedKeySchema.put("type", "struct");
-        nestedKeySchema.putArray("fields").add(((ObjectNode) keySchema).put("field", "after"));
-        icebergSchemaFields(valueSchema, nestedKeySchema, schemaData);
+////        ObjectNode nestedKeySchema = mapper.createObjectNode();
+////        nestedKeySchema.put("type", "struct");
+////        nestedKeySchema.putArray("fields").add(((ObjectNode) keySchema).put("field", "after"));
+////        icebergSchemaFields(valueSchema, nestedKeySchema, schemaData);
         // @TODO raise error
-        //icebergSchemaFields(valueSchema, null, schemaData);
+        icebergSchemaFields(valueSchema, null, schemaData);
       } else {
         icebergSchemaFields(valueSchema, keySchema, schemaData);
       }