Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • /plugins: This will return all plugins that are Connectors, Transformations, Converters, HeaderConverters and Predicates. Plugins will be grouped by plugin .path. This will make it clear to users what's available to use as it's not possible to use a Connector from one path with Transformations from another.

...

  • type.
Code Block
languagejs
{
  "classpathconverter": [
    {
      "class": "org.apache.kafka.connect.transformsconverters.DropHeadersByteArrayConverter",
      "typelocation": "transformationclasspath",
    }
  "location],
  "header_converter": "classpath"
    },[
    {
      "class": "org.apache.kafka.connect.transformsstorage.predicates.HasHeaderKeySimpleHeaderConverter",
      "typelocation": "predicateclasspath",
    }
  ],
  "locationsink": "classpath"
    },[
    {
      "class": "org.apache.kafka.connect.convertersfile.ByteArrayConverterFileStreamSinkConnector",
      "typelocation": "converterclasspath",
    }
  ],
  "locationsource": "classpath"[
    },
    {
      "class": "org.apache.kafka.connect.storage.SimpleHeaderConverter",
      "type": "header_converter"file.FileStreamSourceConnector",
      "location": "classpath"
    }
  ],   
  "/Users/mickael/tmp/path1/transformation": [
    {
      "class": "orgcom.github.apachejcustenborder.kafka.connect.file.FileStreamSinkConnector",
      "type": "sinktransform.common.BytesToString$Key",
      "location": "file:/Users/mickael/tmp/path1path2/kafka-connect-transform-filecommon-30.1.0.014.jar"
    }
  ],
  "/Users/mickael/tmp/path2/": [
    {
      "class": "comorg.github.jcustenborderapache.kafka.connect.transformtransforms.common.BytesToString$KeyDropHeaders",
      "typelocation": "transformation",classpath"
    }
  ],
  "predicate": [
     {
      "locationclass": "file:/Users/mickael/tmp/path2/kafka-connect-transform-common-0.1.0.14.jarorg.apache.kafka.connect.transforms.predicates.HasHeaderKey",
      "location": "classpath"
    }
  ] 
}
  • /plugins/<type>/<name>/configdef: This will return the configdef for the specified plugin. Type can be either sink, source, transformation, predicate, converter or header_converter. Name must be a class name (fully qualified or not) or the Connect alias (class name without the Connector, Converter or Transform suffix) of the plugin.

...