- Connect to External Systems
- Pulsar IO
Manage Connectors
StreamNative Cloud enables you to manage Pulsar IO Connectors by using a variety of tools, including pulsarctl, pulsar-admin, and Terraform.
Note
If you want to update or delete connectors using 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.
pulsarctl sources update \
--name test \
--parallelism 2
You should see the following output:
Updated successfully
And you can further check the status:
pulsarctl 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.
pulsarctl 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.
pulsarctl 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