1. StreamNative Cloud
  2. Connectors

Work with sink connectors

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

Currently, StreamNative Cloud supports the following sink connectors.

Create sink connectors

This section describes how to create sink connectors.

Prerequisites

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

  • Prerequisites for creating an AMQP1_0 sink connector on StreamNative Cloud Console

  • Prerequisites for an AMQP1_0 sink connector connecting to external systems

    • Enable AMQP 1.0-compliant broker service, like RabbitMQ, for remote access.
    • Enable proper access credentials for remote connection.

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.

    FieldDescription
    Sink Type(Read-only) the type of the sink connector.
    Service AccountSelect the service account for creating the sink connector.
    Sink NameEnter a name for the sink connector. The text string supports lowercase characters, numeric characters, and the special character hyphen (-).
    Subscription NameEnter the subscription name for the consumers that consume messages from the input topic.
    Input TopicConfigure 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.
    ReplicasConfigure the number of Pulsar instances to run the sink connector.
    ConfigConfigure 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.

Previous
Work with source connectors