Starting a connector
Starting a connector on your Kafka Connect cluster can be done with a single call the to REST API. The configuration of each connector will depend on the implementation of the connector itself. The following example is an example only and you should not use it verbatim in your clusters. For more information on using the Kafka Connect REST API, see the official Kafka Connect REST API.
|
1 |
curl https://52.203.176.16:8083/connectors -X POST -H 'Content-Type: application/json' -d '{ "name": "sink-connector-example", "config": { "connector.class": "FileStreamSink", "tasks.max": "2", "file": "/tmp/test.sink.txt", "topics": "test" } }' -k -u <YOUR_USER>:<YOUR_PASSWORD> |
