diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/IcebergChangeEventBuilder.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/IcebergChangeEventBuilder.java index 75998515..41d74719 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/IcebergChangeEventBuilder.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/testresources/IcebergChangeEventBuilder.java @@ -44,14 +44,14 @@ public IcebergChangeEventBuilder destination(String destination) { public IcebergChangeEventBuilder addField(String parentFieldName, String name, String val) { ObjectNode nestedField = JsonNodeFactory.instance.objectNode(); nestedField.put(name, val); - this.payload.put(parentFieldName, nestedField); + this.payload.set(parentFieldName, nestedField); return this; } public IcebergChangeEventBuilder addField(String parentFieldName, String name, int val) { ObjectNode nestedField = JsonNodeFactory.instance.objectNode(); nestedField.put(name, val); - this.payload.put(parentFieldName, nestedField); + this.payload.set(parentFieldName, nestedField); return this; } @@ -62,7 +62,7 @@ public IcebergChangeEventBuilder addField(String parentFieldName, String name, b nestedField = (ObjectNode) this.payload.get(parentFieldName); } nestedField.put(name, val); - this.payload.put(parentFieldName, nestedField); + this.payload.set(parentFieldName, nestedField); return this; }