diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java index 995f24ab..aef8f436 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java @@ -65,6 +65,8 @@ public Map getConfigOverrides() { config.put("%mongodb.debezium.source.collection.include.list", "inventory.products"); // IMPORTANT !!! FIX MongoDbConnector KEY FIELD NAME "id"=>"_id" !!! config.put("%mongodb.debezium.transforms", "unwrap,renamekeyfield"); + config.put("%mongodb.delete.tombstone.handling.mode", "rewrite"); + config.put("%mongodb.delete.tombstone.handling.mode.rewrite-with-id", "true"); config.put("%mongodb.debezium.transforms.renamekeyfield.type", "org.apache.kafka.connect.transforms.ReplaceField$Key"); config.put("%mongodb.debezium.transforms.renamekeyfield.renames", "id:_id");