[Yandex Cloud documentation](../../../../index.md) > [Yandex Serverless Integrations](../../../index.md) > [Step-by-step guides](../../index.md) > EventRouter > Managing a connector > Creating a connector > Data Streams

# Creating a connector for Data Streams

{% list tabs group=instructions %}

- Management console {#console}

  1. In the [management console](https://console.yandex.cloud), select the folder where you want to create a [connector](../../../concepts/eventrouter/connector.md).
  1. Navigate to **Serverless Integrations**.
  1. In the left-hand panel, click ![image](../../../../_assets/console-icons/object-align-center-vertical.svg) **EventRouter**.
  1. Select the [bus](../../../concepts/eventrouter/bus.md) you need.
  1. Navigate to the ![image](../../../../_assets/console-icons/broadcast-signal.svg) **Connectors** tab.
  1. In the top-right corner, click **Create connector**.
  1. In the **Source** field, select `Yandex Data Streams`.
  1. Under **Data Streams settings**:

      * Select the [data stream](../../../../data-streams/concepts/glossary.md#stream-concepts) and [dedicated data consumer](../../../../data-streams/concepts/glossary.md#consumers).
      * Select a [service account](../../../../iam/concepts/users/service-accounts.md) that has read permissions for the data stream.

  1. Expand **Additional parameters**:
     
     * Enter a name and description for the [connector](../../../concepts/eventrouter/connector.md). The naming requirements are as follows:
     
         * The name must be from 3 to 63 characters long.
         * It may contain uppercase and lowercase Latin and Cyrillic letters, numbers, hyphens, underscores, and spaces.
         * The first character must be a letter. The last character cannot be a hyphen, underscore, or space.
     
     * Optionally, add labels:
     
         * Click **Add label**.
         * Enter a label in `key: value` format.
         * Press **Enter**.
     
     * Optionally, enable deletion protection. You cannot delete a connector with this option enabled.
  1. Click **Create**.

- CLI {#cli}

  If you do not have the Yandex Cloud CLI yet, [install and initialize it](../../../../cli/quickstart.md#install).

  The folder used by default is the one specified when [creating](../../../../cli/operations/profile/profile-create.md) the CLI profile. To change the default folder, use the `yc config set folder-id <folder_ID>` command. You can also specify a different folder for any command using `--folder-name` or `--folder-id`. If you access a resource by its name, the search will be limited to the default folder. If you access a resource by its ID, the search will be global, i.e., through all folders based on access permissions.

  1. See the description of the CLI command for creating a [connector](../../../concepts/eventrouter/connector.md):

      ```bash
      yc serverless eventrouter connector create data-stream --help
      ```

  1. Create a connector for Data Streams:

      ```bash
      yc serverless eventrouter connector create data-stream \
        --bus-id <bus_ID> \
        --database <DB_path>
        --stream-name <stream_name>
        --consumer <consumer_name>
        --service-account-id <service_account_ID> \
        --name <connector_name> \
        --description "<connector_description>" \
        --labels <label_list> \
        --deletion-protection
      ```

      Where:

      * `--bus-id`: EventRouter [bus](../../../concepts/eventrouter/bus.md) ID.
      * `--database`: [Path](../../../../ydb/operations/connection.md#endpoint-and-path) to the Yandex Managed Service for YDB [database](../../../../ydb/concepts/resources.md#database) specified in the [data stream](../../../../data-streams/concepts/glossary.md#stream-concepts) settings, e.g., `/ru-central1/b1gia87mbaom********/etnudu2n9ri3********`.
      * `--stream-name`: Data stream name.
      * `--consumer`: Name of the [dedicated data consumer](../../../../data-streams/concepts/glossary.md#consumers).
      * `--service-account-id`: ID of the [service account](../../../../iam/concepts/users/service-accounts.md) that has read permissions for the data stream.
      * `--name`: Connector name. Follow these naming requirements:

          * The name must be from 3 to 63 characters long.
          * It may contain uppercase and lowercase Latin and Cyrillic letters, numbers, hyphens, underscores, and spaces.
          * The first character must be a letter. The last character cannot be a hyphen, underscore, or space.

      * `--description`: Connector description. This is an optional setting.
      * `--labels`: List of labels. This is an optional setting.

          You can specify one or more labels separated by commas in `<key1>=<value1>,<key2>=<value2>` format.

      * `--deletion-protection`: Connector deletion protection. By default, protection is disabled. You cannot delete a connector with this option enabled. To disable deletion protection, specify `--no-deletion-protection`. This is an optional setting.

      Result:

      ```text
      id: f66g6jcnc5no********
      bus_id: f66qn4p7uk6p********
      folder_id: b1g681qpemb4********
      cloud_id: b1gia87mbaom********
      created_at: "2025-02-21T10:53:25.994124Z"
      name: yds-via-cli
      description: created via cli
      labels:
        interface: yccli
        owner: admin
      source:
        data_stream:
          database: /ru-central1/b1gia87mbaom********/etntd0p5tauu********
          stream_name: my-ydb-flow
          consumer: consumer-one
          service_account_id: ajelprpohp7r********
      deletion_protection: true
      status: RUNNING
      ```

- Terraform {#tf}

  With [Terraform](https://www.terraform.io/), you can quickly create a cloud infrastructure in Yandex Cloud and manage it using configuration files. These files store the infrastructure description written in HashiCorp Configuration Language (HCL). If you change the configuration files, Terraform automatically detects which part of your configuration is already deployed, and what should be added or removed.
  
  Terraform is distributed under the [Business Source License](https://github.com/hashicorp/terraform/blob/main/LICENSE). The [Yandex Cloud provider for Terraform](https://github.com/yandex-cloud/terraform-provider-yandex) is distributed under the [MPL-2.0](https://www.mozilla.org/en-US/MPL/2.0/) license.
  
  For more information about the provider resources, see the guides on the [Terraform](https://www.terraform.io/docs/providers/yandex/index.html) website or [its mirror](../../../../terraform/index.md).

  If you do not have Terraform yet, [install it and configure the Yandex Cloud provider](../../../../tutorials/infrastructure-management/terraform-quickstart.md#install-terraform).
  
  
  To manage infrastructure using Terraform under a service account or user accounts (a Yandex account, a federated account, or a local user), [authenticate](../../../../terraform/authentication.md) using the appropriate method.

  To create a [connector](../../../concepts/eventrouter/connector.md) for Data Streams:

  1. In the configuration file, describe the resources you want to create:

      ```hcl
      resource "yandex_serverless_eventrouter_connector" "example_connector" {
        bus_id              = "<bus_ID>"
        name                = "<connector_name>"
        description         = "<connector_description>"
        deletion_protection = <true|false>

        labels = {
          <key_1> = "<value_1>"
          <key_2> = "<value_2>"
          ...
          <key_n> = "<value_n>"
        }

        ymq {
          database           = "<DB_path>"
          stream_name        = "<stream_name>"
          consumer           = "<consumer_name>"
          service_account_id = "<service_account_ID>"
        }
      }
      ```

      Where:

      * `bus_id`: EventRouter [bus](../../../concepts/eventrouter/bus.md) ID.
      * `name`: Connector name. Follow these naming requirements:

          * The name must be from 3 to 63 characters long.
          * It may contain uppercase and lowercase Latin and Cyrillic letters, numbers, hyphens, underscores, and spaces.
          * The first character must be a letter. The last character cannot be a hyphen, underscore, or space.

      * `description`: Connector description. This is an optional setting.
      * `deletion_protection`: Connector deletion protection, `true` or `false`. You cannot delete a connector with this option enabled. This is an optional setting.
      * `labels`: List of labels Provide labels in `<key> = "<value>"` format. This is an optional setting.
      * `database`: [Path](../../../../ydb/operations/connection.md#endpoint-and-path) to the Yandex Managed Service for YDB [database](../../../../ydb/concepts/resources.md#database) specified in the [data stream](../../../../data-streams/concepts/glossary.md#stream-concepts) settings, e.g., `/ru-central1/b1gia87mbaom********/etnudu2n9ri3********`.
      * `stream_name`: Data stream name.
      * `consumer`: Name of the [dedicated data consumer](../../../../data-streams/concepts/glossary.md#consumers).
      * `service_account_id`: ID of the [service account](../../../../iam/concepts/users/service-accounts.md) that has read permissions for the data stream.

      For more on the properties of the `yandex_serverless_eventrouter_connector` resource, see [this provider guide](../../../../terraform/resources/serverless_eventrouter_connector.md).

  1. Create the resources:

      1. In the terminal, navigate to the configuration file directory.
      1. Make sure the configuration is correct using this command:
      
         ```bash
         terraform validate
         ```
      
         If the configuration is valid, you will get this message:
      
         ```bash
         Success! The configuration is valid.
         ```
      
      1. Run this command:
      
         ```bash
         terraform plan
         ```
      
         You will see a list of resources and their properties. No changes will be made at this step. Terraform will show any errors in the configuration.
      1. Apply the configuration changes:
      
         ```bash
         terraform apply
         ```
      
      1. Type `yes` and press **Enter** to confirm the changes.

      Terraform will create all the required resources. You can check the new resources in the [management console](https://console.yandex.cloud) or using this [CLI](../../../../cli/index.md) command:

      ```bash
      yc serverless eventrouter connector list
      ```

- API {#api}

  To create a [connector](../../../concepts/eventrouter/connector.md) for Data Streams, use the [Create](../../../eventrouter/api-ref/Connector/create.md) REST API method for the [connector](../../../eventrouter/api-ref/Connector/index.md) resource or the [connector/Create](../../../eventrouter/api-ref/grpc/Connector/create.md) gRPC API call.

{% endlist %}

By default, the system creates a running connector. [Stop](stop.md) the connector to prevent it from sending messages to the bus.