[KAFKA-4929] Transformation Key/Value type references should be to class name(), not canonicalName()

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.10.2.0
• Fix Version/s: 0.11.0.0
• Component/s: connect
• Assignee: Unassigned
• Reporter: bruce szalwinski
• Created: 21/Mar/17 21:39
• Updated: 06/Apr/17 21:53
• Resolved: 22/Mar/17 21:02

Description

The docs suggest that referencing the Key/Value transformations is done as follows:

    "transforms": "replaceFieldValue",
    "transforms.replaceFieldValue.type":  "org.apache.kafka.connect.transforms.ReplaceField.Value"

But that results in a validation failure saying that the class cannot be found.

            "value": {
                "errors": [
                    "Invalid value org.apache.kafka.connect.transforms.ReplaceField.Value for configuration transforms.replaceFieldValue.type: Class org.apache.kafka.connect.transforms.ReplaceField.Value could not be found.",
                    "Invalid value null for configuration transforms.replaceFieldValue.type: Not a Transformation"
                ],
                "name": "transforms.replaceFieldValue.type",
                "recommended_values": [
                    "org.apache.kafka.connect.transforms.ExtractField.Key",
                    "org.apache.kafka.connect.transforms.ExtractField.Value",
                    "org.apache.kafka.connect.transforms.HoistField.Key",
                    "org.apache.kafka.connect.transforms.HoistField.Value",
                    "org.apache.kafka.connect.transforms.InsertField.Key",
                    "org.apache.kafka.connect.transforms.InsertField.Value",
                    "org.apache.kafka.connect.transforms.MaskField.Key",
                    "org.apache.kafka.connect.transforms.MaskField.Value",
                    "org.apache.kafka.connect.transforms.RegexRouter",
                    "org.apache.kafka.connect.transforms.ReplaceField.Key",
                    "org.apache.kafka.connect.transforms.ReplaceField.Value",
                    "org.apache.kafka.connect.transforms.SetSchemaMetadata.Key",
                    "org.apache.kafka.connect.transforms.SetSchemaMetadata.Value",
                    "org.apache.kafka.connect.transforms.TimestampRouter",
                    "org.apache.kafka.connect.transforms.ValueToKey"
                ],

Since the Key / Value transformations are defined as static nested classes, the proper notation is

    "transforms": "replaceFieldValue",
    "transforms.replaceFieldValue.type":  "org.apache.kafka.connect.transforms.ReplaceField$Value"

Issue Links

• links to: GitHub Pull Request #2720