Create, update, and delete sink connectors

This document describes how to work with sink connectors through StreamNative Console. In addition, you can also use the pulsarctl CLI tool to create and manage sink connectors. For details, see work with connectors using the pulsarctl CLI tool.

Create sink connectors

This section describes how to create sink connectors.

Prerequisites

This section lists prerequisites for creating supported sink connectors on StreamNative Console and for sink connectors connecting to external systems

Steps

1. From the left navigation pane, under Resources, click Connectors.

2. Select the Created Sinks tab.

3. Click CREATE A SINK. A drop-down menu appears and lists available sink connectors.

   

4. Click the icon of the sink connector that you want to create and enter the page where you can configure the sink connector.

   

5. Configure the sink connector. See the tables of valid configuration options below.

6. Click SUBMIT.

   Select a tabAMQP 1.0AWS LambdaAWS SQSCloud StorageElasticsearchGoogle BigQueryKinesisSnowflakeAWS EventBridge

   Field	Description
   Sink Type	(Read-only) the type of the sink connector.
   Service Account	Select the service account for creating the sink connector.
   Sink Name	Enter a name for the sink connector. The text string supports lowercase characters, numeric characters, and the special character hyphen (-).
   Subscription Name	Enter the subscription name for the consumers that consume messages from the input topic.
   Input Topic	Configure the input topic for the sink connector. - Tenant: select the tenant you want to export messages from. - Namespace: select the namespace you want to export messages from. - Topic: select the topic you want to export messages from.
   Replicas	Configure the number of Pulsar instances to run the sink connector.
   Config	Configure the sink connector. - Protocol: enter the protocol. amqp is the default setting. - Host: enter the AMQP service host. - Port: enter the AMQP service port. - Username: enter the username to authenticate to the AMQP1_0 sink connector. - Password: enter the password to authenticate to the AMQP1_0 sink connector. - Queue: enter the name of the queue that messages should be read from or written to.

Update sink connectors

You can update some fields to make changes to the configuration of a sink connector after it is created.

1. From the left navigation pane, under Resources, click Connectors.

2. Select the Created Sinks tab.

3. Click the ellipsis at the end of the row of the connector that you want to update, and then click Edit.

4. Edit the configuration that you want to change. For details, see create sink connectors.

5. Click SUBMIT.

Delete sink connectors

1. From the left navigation pane, under Resources, click Connectors.

2. Select the Created Sinks tab.

3. Click the ellipsis at the end of the row of the connector that you want to delete, and then click Delete.

4. Enter the sink connector name and then click Confirm.