From b91706cb44b4f8ab594912d17f85c61b5a17d3cb Mon Sep 17 00:00:00 2001
From: Ismail Simsek <6005685+ismailsimsek@users.noreply.github.com>
Date: Sun, 16 Jun 2024 00:43:26 +0200
Subject: [PATCH] Test consumer without event flattening

---
 .../io/debezium/server/iceberg/IcebergChangeEvent.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java
index 7d91c399..c777f913 100644
--- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeEvent.java
+++ b/debezium-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);
       }