MINOR: rename ConfigName.RENAME to ConfigName.RENAMES for replaceFiled (

#17369) Reviewers: Andrew Schofield <[email protected]>, TengYao Chi <[email protected]>, Chia-Ping Tsai <[email protected]>
apache · Oct 4, 2024 · 3bb408c · 3bb408c
1 parent 529095b
commit 3bb408c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java
@@ -412,7 +412,7 @@ private static Map<String, Schema.Type> parseFieldTypes(List<String> mappings) {
         for (String mapping : mappings) {
             final String[] parts = mapping.split(":");
             if (parts.length > 2) {
-                throw new ConfigException(ReplaceField.ConfigName.RENAME, mappings, "Invalid rename mapping: " + mapping);
+                throw new ConfigException(ReplaceField.ConfigName.RENAMES, mappings, "Invalid rename mapping: " + mapping);
             }
             if (parts.length == 1) {
                 Schema.Type targetType;

diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java
@@ -51,7 +51,7 @@ interface ConfigName {
         String EXCLUDE = "exclude";
         String INCLUDE = "include";
 
-        String RENAME = "renames";
+        String RENAMES = "renames";
         String REPLACE_NULL_WITH_DEFAULT_CONFIG = "replace.null.with.default";
     }
 
@@ -60,7 +60,7 @@ interface ConfigName {
                     "Fields to exclude. This takes precedence over the fields to include.")
             .define(ConfigName.INCLUDE, ConfigDef.Type.LIST, Collections.emptyList(), ConfigDef.Importance.MEDIUM,
                     "Fields to include. If specified, only these fields will be used.")
-            .define(ConfigName.RENAME, ConfigDef.Type.LIST, Collections.emptyList(),
+            .define(ConfigName.RENAMES, ConfigDef.Type.LIST, Collections.emptyList(),
                 ConfigDef.LambdaValidator.with(
                     (name, value) -> {
                         @SuppressWarnings("unchecked")
@@ -93,7 +93,7 @@ public void configure(Map<String, ?> configs) {
 
         exclude = new HashSet<>(config.getList(ConfigName.EXCLUDE));
         include = new HashSet<>(config.getList(ConfigName.INCLUDE));
-        renames = parseRenameMappings(config.getList(ConfigName.RENAME));
+        renames = parseRenameMappings(config.getList(ConfigName.RENAMES));
         reverseRenames = invert(renames);
         replaceNullWithDefault = config.getBoolean(ConfigName.REPLACE_NULL_WITH_DEFAULT_CONFIG);
 
@@ -105,7 +105,7 @@ static Map<String, String> parseRenameMappings(List<String> mappings) {
         for (String mapping : mappings) {
             final String[] parts = mapping.split(":");
             if (parts.length != 2) {
-                throw new ConfigException(ConfigName.RENAME, mappings, "Invalid rename mapping: " + mapping);
+                throw new ConfigException(ConfigName.RENAMES, mappings, "Invalid rename mapping: " + mapping);
             }
             m.put(parts[0], parts[1]);
         }