DBZ-8024: Fix bug with multiple transforms

debezium · Jul 5, 2024 · ade4009 · ade4009
1 parent 93a8134
commit ade4009
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/debezium-operator-api/src/main/java/io/debezium/operator/api/config/ConfigMapping.java b/debezium-operator-api/src/main/java/io/debezium/operator/api/config/ConfigMapping.java
@@ -105,10 +105,9 @@ record NamedItem(String name, ConfigMappable item) {
 
         named.stream()
                 .map(NamedItem::name)
-                .reduce((x, y) -> String.join(","))
+                .reduce((x, y) -> x + "," + y)
                 .ifPresent(names -> put(key, names));
 
-
         named.forEach(item -> putAll(key + "." + item.name, item.item));
         return this;
     }

diff --git a/debezium-operator-api/src/test/java/io/debezium/operator/api/config/ConfigMappingTest.java b/debezium-operator-api/src/test/java/io/debezium/operator/api/config/ConfigMappingTest.java
@@ -83,7 +83,7 @@ void shouldAddList() {
 
         config.putList("transforms", transformations, "Reroute");
 
-        assertThat(config.getAsMap()).containsEntry("transforms", "");
+        assertThat(config.getAsMap()).containsEntry("transforms", "Reroute0,Reroute1");
         assertThat(config.getAsMap()).containsEntry("transforms.Reroute0.type", "io.debezium.transforms.ByLogicalTableRouter");
         assertThat(config.getAsMap()).containsEntry("transforms.Reroute0.negate", "false");
         assertThat(config.getAsMap()).containsEntry("transforms.Reroute1.type", "io.debezium.transforms.ByLogicalTableRouter");
@@ -93,7 +93,7 @@ void shouldAddList() {
                 "transforms.Reroute0.type=io.debezium.transforms.ByLogicalTableRouter\n" +
                 "transforms.Reroute1.negate=true\n" +
                 "transforms.Reroute1.type=io.debezium.transforms.ByLogicalTableRouter\n" +
-                "transforms=");
+                "transforms=Reroute0,Reroute1");
     }
 
     @Test