Add mongodb flattening settings to example config

memiiso · May 20, 2024 · 533998e · 533998e
1 parent a71b6fe
commit 533998e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...eberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java b/...eberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java
@@ -65,6 +65,8 @@ public Map<String, String> 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");