diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PluginDiscovery.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PluginDiscovery.java index be55daf571513..d31ce6d1d7aac 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PluginDiscovery.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PluginDiscovery.java @@ -106,7 +106,7 @@ private static List> transformationPlugins(Refle Collections.sort(transformationPlugins, new Comparator>() { @Override public int compare(Class a, Class b) { - return a.getCanonicalName().compareTo(b.getCanonicalName()); + return a.getName().compareTo(b.getName()); } }); diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java index 36373eb0e98eb..bb4b53927d56f 100644 --- a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java +++ b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java @@ -31,8 +31,8 @@ public abstract class ExtractField> implements Transf public static final String OVERVIEW_DOC = "Extract the specified field from a Struct when schema present, or a Map in the case of schemaless data." - + "

Use the concrete transformation type designed for the record key (" + Key.class.getCanonicalName() + ") " - + "or value (" + Value.class.getCanonicalName() + ")."; + + "

Use the concrete transformation type designed for the record key (" + Key.class.getName() + ") " + + "or value (" + Value.class.getName() + ")."; private static final String FIELD_CONFIG = "field"; diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java index 1035e97a41433..a852c797a3611 100644 --- a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java +++ b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java @@ -33,8 +33,8 @@ public abstract class HoistField> implements Transfor public static final String OVERVIEW_DOC = "Wrap data using the specified field name in a Struct when schema present, or a Map in the case of schemaless data." - + "

Use the concrete transformation type designed for the record key (" + Key.class.getCanonicalName() + ") " - + "or value (" + Value.class.getCanonicalName() + ")."; + + "

Use the concrete transformation type designed for the record key (" + Key.class.getName() + ") " + + "or value (" + Value.class.getName() + ")."; private static final String FIELD_CONFIG = "field"; diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java index 441129a8f9efa..5e472a907c3f4 100644 --- a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java +++ b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java @@ -42,8 +42,8 @@ public abstract class InsertField> implements Transfo public static final String OVERVIEW_DOC = "Insert field(s) using attributes from the record metadata or a configured static value." - + "

Use the concrete transformation type designed for the record key (" + Key.class.getCanonicalName() + ") " - + "or value (" + Value.class.getCanonicalName() + ")."; + + "

Use the concrete transformation type designed for the record key (" + Key.class.getName() + ") " + + "or value (" + Value.class.getName() + ")."; private interface ConfigName { String TOPIC_FIELD = "topic.field"; diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java index f9946a025721f..050c549c97e16 100644 --- a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java +++ b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java @@ -42,8 +42,8 @@ public abstract class MaskField> implements Transform public static final String OVERVIEW_DOC = "Mask specified fields with a valid null value for the field type (i.e. 0, false, empty string, and so on)." - + "

Use the concrete transformation type designed for the record key (" + Key.class.getCanonicalName() + ") " - + "or value (" + Value.class.getCanonicalName() + ")."; + + "

Use the concrete transformation type designed for the record key (" + Key.class.getName() + ") " + + "or value (" + Value.class.getName() + ")."; private static final String FIELDS_CONFIG = "fields"; 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 index 8bdc15333a8bf..ee08945416683 100644 --- 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 @@ -39,7 +39,9 @@ public abstract class ReplaceField> implements Transformation { - public static final String OVERVIEW_DOC = "Filter or rename fields."; + public static final String OVERVIEW_DOC = "Filter or rename fields." + + "

Use the concrete transformation type designed for the record key (" + Key.class.getName() + ") " + + "or value (" + Value.class.getName() + ")."; interface ConfigName { String BLACKLIST = "blacklist"; diff --git a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java index d34a43060ab5d..bb581de178024 100644 --- a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java +++ b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java @@ -30,8 +30,8 @@ public abstract class SetSchemaMetadata> implements Transformation { public static final String OVERVIEW_DOC = - "Set the schema name, version or both on the record's key (" + Key.class.getCanonicalName() + ")" - + " or value (" + Value.class.getCanonicalName() + ") schema."; + "Set the schema name, version or both on the record's key (" + Key.class.getName() + ")" + + " or value (" + Value.class.getName() + ") schema."; private interface ConfigName { String SCHEMA_NAME = "schema.name";