THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
JIRA: KAFKA-5657
Released: 1.0.11.0.0
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Currently we don't expose information about whether a connector is a source or sink in its description. This is useful when, e.g., categorizing connectors in a UI. Given naming conventions we try to encourage you might be able to determine this via the connector's class name, but that isn't reliable. We would also like to expose a Connector's version information.
Public Interfaces
We will modify the following REST API endpoint for Connect:
| Code Block |
|---|
GET /connector-pluginsconnectors |
Proposed Changes
The aforementioned endpoint currently returns the following structure:
| Code Block |
|---|
[ { "class": "org.apache.kafka.connect.file.FileStreamSourceConnector" }, { "class": "org.apache.kafka.connect.file.FileStreamSinkConnector" } HTTP/1.1 200 OK Content-Type: application/json ["my-jdbc-source", "my-hdfs-sink"] |
We will add a `type` field to each element of the array that indicates whether the given Connector is a Source or SInk. e.g.:
| Code Block |
|---|
[
{
"classname": "org.apache.kafka.connect.file.FileStreamSourceConnectormy-jdbc-source",
"type": "source",
"version": "0.11.0.0"
},
{
"classname": "org.apache.kafka.connect.file.FileStreamSinkConnectormy-hdfs-sink",
"type": "sink",
"version": "0.11.0.0"
}
] |
Compatibility, Deprecation, and Migration Plan
...