Yandex Cloud
  • Сервисы
  • Решения
  • Почему Yandex Cloud
  • Сообщество
  • Тарифы
  • Документация
  • Связаться с нами
Подключиться
Language / Region
© 2022 ООО «Яндекс.Облако»
Yandex Managed Service for Apache Kafka®
  • Начало работы
  • Пошаговые инструкции
    • Все инструкции
    • Информация об имеющихся кластерах
    • Создание кластера
    • Подключение к кластеру
    • Остановка и запуск кластера
    • Обновление версии Apache Kafka®
    • Изменение настроек кластера
    • Управление хостами Apache Kafka®
    • Работа с топиками и разделами
    • Управление учетными записями Kafka
    • Управление коннекторами
    • Просмотр логов кластера
    • Удаление кластера
    • Мониторинг состояния кластера и хостов
  • Практические руководства
    • Все руководства
    • Поставка данных в Managed Service for ClickHouse
    • Настройка Kafka Connect для работы с Managed Service for Apache Kafka®
    • Поставка данных в ksqlDB
    • Использование схем формата данных с Managed Service for Apache Kafka®
      • Обзор
      • Работа с управляемым реестром схем формата данных
      • Работа с реестром схем формата данных Confluent
    • Миграция данных в Managed Service for Apache Kafka®
    • Поставка данных с помощью Debezium
  • Концепции
    • Взаимосвязь ресурсов сервиса
    • Топики и разделы
    • Брокеры
    • Производители и потребители
    • Управление схемами данных
    • Классы хостов
    • Сеть в Managed Service for Apache Kafka®
    • Квоты и лимиты
    • Типы хранилища
    • Коннекторы
    • Техническое обслуживание
    • Настройки Apache Kafka®
  • Управление доступом
  • Правила тарификации
  • Справочник API
    • Аутентификация в API
    • gRPC (англ.)
      • Overview
      • ClusterService
      • ConnectorService
      • ResourcePresetService
      • TopicService
      • UserService
      • OperationService
    • REST (англ.)
      • Overview
      • Cluster
        • Overview
        • create
        • delete
        • get
        • list
        • listHosts
        • listLogs
        • listOperations
        • move
        • rescheduleMaintenance
        • start
        • stop
        • streamLogs
        • update
      • Connector
        • Overview
        • create
        • delete
        • get
        • list
        • pause
        • resume
        • update
      • ResourcePreset
        • Overview
        • get
        • list
      • Topic
        • Overview
        • create
        • delete
        • get
        • list
        • update
      • User
        • Overview
        • create
        • delete
        • get
        • grantPermission
        • list
        • revokePermission
        • update
      • Operation
        • Overview
        • get
  • История изменений
  • Вопросы и ответы
  1. Справочник API
  2. REST (англ.)
  3. Connector
  4. get

Method get

Статья создана
Yandex.Cloud
  • HTTP request
  • Path parameters
  • Response

Returns the specified Apache Kafka Connector resource.

To get the list of available Apache Kafka Connector resources, make a list request.

HTTP request

GET https://mdb.api.cloud.yandex.net/managed-kafka/v1/clusters/{clusterId}/connectors/{connectorName}

Path parameters

Parameter Description
clusterId Required. ID of the Apache Kafka Cluster resource to return. To get the cluster ID use a list request. The maximum string length in characters is 50.
connectorName Required. Name of the Apache Kafka Connector resource to return. To get the name of the connector use a list request. The maximum string length in characters is 256. Value must match the regular expression [a-zA-Z0-9_-]*.

Response

HTTP Code: 200 - OK

{
  "name": "string",
  "tasksMax": "integer",
  "properties": "object",
  "health": "string",
  "status": "string",
  "clusterId": "string",
  "connectorConfigMirrormaker": {
    "sourceCluster": {
      "alias": "string",

      // `connectorConfigMirrormaker.sourceCluster` includes only one of the fields `thisCluster`, `externalCluster`
      "thisCluster": {},
      "externalCluster": {
        "bootstrapServers": "string",
        "saslUsername": "string",
        "saslMechanism": "string",
        "securityProtocol": "string"
      },
      // end of the list of possible fields`connectorConfigMirrormaker.sourceCluster`

    },
    "targetCluster": {
      "alias": "string",

      // `connectorConfigMirrormaker.targetCluster` includes only one of the fields `thisCluster`, `externalCluster`
      "thisCluster": {},
      "externalCluster": {
        "bootstrapServers": "string",
        "saslUsername": "string",
        "saslMechanism": "string",
        "securityProtocol": "string"
      },
      // end of the list of possible fields`connectorConfigMirrormaker.targetCluster`

    },
    "topics": "string",
    "replicationFactor": "integer"
  }
}

An Apache Kafka® connector resource.

Field Description
name string

Name of the connector.

tasksMax integer (int64)

Maximum number of tasks. Default is the number of brokers

properties object

Properties passed with connector config to Connect service Example: 'sync.topics.config.enabled: true'

health string
Connector health.
  • HEALTH_UNKNOWN: State of the connector is unknown.
  • ALIVE: Connector is running.
  • DEAD: Connector is failed to start.
status string
Current status of the connector.
  • STATUS_UNKNOWN: Connector state is unknown.
  • RUNNING: Connector is running normally.
  • ERROR: Connector encountered a problem and cannot operate.
  • PAUSED: Connector paused.
clusterId string

ID of the Apache Kafka cluster that the connector belongs to.

connectorConfigMirrormaker object

An An Apache Kafka® MirrorMaker connector resource.

connectorConfigMirrormaker.
sourceCluster
object

Source cluster resource settings.

Resource ClusterConnection - settings of connection to clusters, that are source or target of MirrorMaker clusters.

connectorConfigMirrormaker.
sourceCluster.
alias
string

Alias of ClusterConnection resource. For example: 'source', 'target', ...

connectorConfigMirrormaker.
sourceCluster.
thisCluster
object
If type is 'this_cluster' - we connect to cluster that is handle Kafka Connect Worker, on which we try to register connector.
connectorConfigMirrormaker.sourceCluster includes only one of the fields thisCluster, externalCluster

Resource of cluster_connection type 'this_cluster'.

connectorConfigMirrormaker.
sourceCluster.
externalCluster
object
If type is 'external_cluster' - we connect to cluster that is not handle Kafka Connect Worker, on which we try to register connector.
connectorConfigMirrormaker.sourceCluster includes only one of the fields thisCluster, externalCluster

Resource of connection to external cluster. It contains all settings of connection to external cluster.

connectorConfigMirrormaker.
sourceCluster.
externalCluster.
bootstrapServers
string

List bootstrap servers of cluster, separated by ','

connectorConfigMirrormaker.
sourceCluster.
externalCluster.
saslUsername
string

Sasl username which we use to connect to cluster.

connectorConfigMirrormaker.
sourceCluster.
externalCluster.
saslMechanism
string

Sasl mechanism, which we should use to connect to cluster.

connectorConfigMirrormaker.
sourceCluster.
externalCluster.
securityProtocol
string

Security protocol, which we should use to connect to cluster.

connectorConfigMirrormaker.
targetCluster
object

Target cluster resource settings.

Resource ClusterConnection - settings of connection to clusters, that are source or target of MirrorMaker clusters.

connectorConfigMirrormaker.
targetCluster.
alias
string

Alias of ClusterConnection resource. For example: 'source', 'target', ...

connectorConfigMirrormaker.
targetCluster.
thisCluster
object
If type is 'this_cluster' - we connect to cluster that is handle Kafka Connect Worker, on which we try to register connector.
connectorConfigMirrormaker.targetCluster includes only one of the fields thisCluster, externalCluster

Resource of cluster_connection type 'this_cluster'.

connectorConfigMirrormaker.
targetCluster.
externalCluster
object
If type is 'external_cluster' - we connect to cluster that is not handle Kafka Connect Worker, on which we try to register connector.
connectorConfigMirrormaker.targetCluster includes only one of the fields thisCluster, externalCluster

Resource of connection to external cluster. It contains all settings of connection to external cluster.

connectorConfigMirrormaker.
targetCluster.
externalCluster.
bootstrapServers
string

List bootstrap servers of cluster, separated by ','

connectorConfigMirrormaker.
targetCluster.
externalCluster.
saslUsername
string

Sasl username which we use to connect to cluster.

connectorConfigMirrormaker.
targetCluster.
externalCluster.
saslMechanism
string

Sasl mechanism, which we should use to connect to cluster.

connectorConfigMirrormaker.
targetCluster.
externalCluster.
securityProtocol
string

Security protocol, which we should use to connect to cluster.

connectorConfigMirrormaker.
topics
string

List of Kafka topics, separated by ','

connectorConfigMirrormaker.
replicationFactor
integer (int64)

Replication factor for automatically created topics.

Была ли статья полезна?

Language / Region
© 2022 ООО «Яндекс.Облако»
В этой статье:
  • HTTP request
  • Path parameters
  • Response