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> |
By Instaclustr Support
Need Support?
Experiencing difficulties on the website or console?
Already have an account?
Need help with your cluster?
Contact Support
Why sign up?