- Connect to External Systems
- Pulsar IO
Manage Connectors
StreamNative Cloud enables you to manage Pulsar IO Connectors by using a variety of tools, including snctl, pulsarctl, pulsar-admin, and Terraform.
Note
If you want to update or delete connectors using snctl, pulsarctl or pulsar-admin, make sure you have set up your client tool. For more information, see set up client tools.
Update a connector
When you want to modify configurations or update resources for connectors, you can update connectors using multiple tools.
The following example shows how to update the parallelism of the data generator source connector test to 2 using different tools.
snctl pulsar admin sources update \
--name test \
--parallelism 2
You should see the following output:
Updated successfully
And you can further check the status:
snctl pulsar admin sources status --name test
{
"numInstances": 2,
"numRunning": 2,
"instances": [
{
"instanceId": 0,
"status": {
"running": true,
"error": "",
"numRestarts": 0,
"numReceivedFromSource": 1799,
"numSystemExceptions": 0,
"latestSystemExceptions": [],
"numSourceExceptions": 0,
"latestSourceExceptions": [],
"numWritten": 1799,
"lastReceivedTime": 1693946327331,
"workerId": "test"
}
},
{
"instanceId": 1,
"status": {
"running": true,
"error": "",
"numRestarts": 0,
"numReceivedFromSource": 689,
"numSystemExceptions": 0,
"latestSystemExceptions": [],
"numSourceExceptions": 0,
"latestSourceExceptions": [],
"numWritten": 689,
"lastReceivedTime": 1693946327129,
"workerId": "test"
}
}
]
}
Delete a connector
The following example shows how to delete the data generator source connector test using different tools.
To delete the source connector test, use the following command.
snctl pulsar admin sources delete --tenant public --namespace default --name test
You should see the following output:
Deleted test successfully
If you want to verify whether the source connector has been deleted successfully, run the following command.
snctl pulsar admin sources get --tenant public --namespace default --name test
You should see the following output:
[✖] code: 500 reason: failed to perform the request: responseCode: 404, responseMessage: sources.compute.functionmesh.io "test-XXXXX" not found