Versions Compared

Key

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

...

  • /connector-plugins: This endpoint will be updated to allow listing all plugins. A new query parameter "connectors_onlyconnectorsOnly" will be added and it will default to true so it's fully compatible with the current behavior. Users will be able to list all Connectors, Transformations, Converters, HeaderConverters and Predicates plugins by setting it to false.

For example GET /connector-plugins?connectors_onlyconnectorsOnly=false will return:

Code Block
languagejs
[
  {
    "class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
    "type": "sink",
    "version": "3.0.0"
  },
  {
    "class": "org.apache.kafka.connect.converters.ByteArrayConverter",
    "type": "converter"
  },
  {
    "class": "org.apache.kafka.connect.transforms.Cast",
    "type": "transformation"
  },
  {
    "class": "org.apache.kafka.connect.transforms.predicates.HasHeaderKey",
    "type": "predicate"
  },
  {
    "class": "org.apache.kafka.connect.storage.SimpleHeaderConverter",
    "type": "header_converter"
  },
  ...
]

...

  • Listing connector plugin will accept an optional query parameter "connectors_onlyconnectorsOnly"  that defaults to true
Code Block
languagejava
@GET
@Path("/")
public List<ConnectorPluginInfo> listConnectorPlugins(@DefaultValue("true") @QueryParam("connectors_onlyconnectorsOnly") boolean connectorsOnly) {}

...