diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java index 2dce780a..22b515bf 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java @@ -86,10 +86,6 @@ public Map getConfigOverrides() { config.put("quarkus.profile", "mysql"); config.put("%mysql.debezium.source.connector.class", "io.debezium.connector.mysql.MySqlConnector"); config.put("%mysql.debezium.source.table.whitelist", "inventory.customers,inventory.test_delete_table"); - // run test without event flattening - config.put("debezium.transforms", ","); - config.put("debezium.source.tombstones.on.delete", "false"); - return config; }