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