THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
/connector-plugins
: This endpoint will be updated to allow listing all plugins. A new query parameter "connectors_only
connectorsOnly
" 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 | ||
---|---|---|
| ||
[ { "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_only
connectorsOnly
" that defaults to true
Code Block | ||
---|---|---|
| ||
@GET @Path("/") public List<ConnectorPluginInfo> listConnectorPlugins(@DefaultValue("true") @QueryParam("connectors_onlyconnectorsOnly") boolean connectorsOnly) {} |
...