Add option to change case of destination/iceberg table names

memiiso · Jul 24, 2024 · 946abf7 · 946abf7
1 parent e79fdd2
commit 946abf7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java b/...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java
@@ -336,10 +336,10 @@ public void testMapDestination() {
     assertEquals(TableIdentifier.of(Namespace.of(namespace), "debeziumcdc_table"), icebergConsumer.mapDestination("table2"));
     icebergConsumer.destinationUppercaseTableNames = true;
     icebergConsumer.destinationLowercaseTableNames = false;
-    assertEquals(TableIdentifier.of(Namespace.of(namespace.toUpperCase()), "DEBEZIUMCDC_TABLE_LOWERCASE"), icebergConsumer.mapDestination("table_lowercase"));
+    assertEquals(TableIdentifier.of(Namespace.of(namespace), "DEBEZIUMCDC_TABLE_LOWERCASE"), icebergConsumer.mapDestination("table_lowercase"));
     icebergConsumer.destinationUppercaseTableNames = false;
     icebergConsumer.destinationLowercaseTableNames = true;
-    assertEquals(TableIdentifier.of(Namespace.of(namespace.toLowerCase()), "debeziumcdc_table_camelcase"), icebergConsumer.mapDestination("table_CamelCase"));
+    assertEquals(TableIdentifier.of(Namespace.of(namespace), "debeziumcdc_table_camelcase"), icebergConsumer.mapDestination("table_CamelCase"));
   }
 
   public static class TestProfile implements QuarkusTestProfile {