Перейти к содержимому

Подключение к реестру схем

Чтобы подключиться к реестру схем:

  1. Настройте подключение.
  2. Зарегистрируйте первую схему и убедитесь, что подключение работает.

1. Настройте подключение

Заголовок раздела «1. Настройте подключение»

Настроить подключение можно двумя способами:

Подключитесь из внутренней сети

Заголовок раздела «Подключитесь из внутренней сети»
  • Веб-консоль
  • MWS CLI
  • API

  1. В веб-консоли выберите нужный проект.

  2. В списке сервисов выберите Managed Kafka.

  3. Нажмите на имя нужного кластера.

  4. Перейдите на вкладку Сети и затем на вкладку Реестр схем.

  5. Сохраните любой адрес реестра схем из блока Внутреннее подключение. Адреса находятся в столбце URL.

  6. Перейдите на вкладку Пользователи.

  7. В списке пользователей найдите и сохраните имя нужного пользователя.

  8. Убедитесь, что у вас есть ВМ в сервисе Compute, подключенная к одной сети с кластером. Если нет, создайте ее.

  9. Подключитесь к ВМ по SSH.

  10. Задайте переменные окружения:

    bash
    export SCHEMA_REGISTRY_URL="<адрес реестра схем>"
    export USERNAME="<имя пользователя>"
    export PASSWORD="<пароль>"

Подключитесь из внешней сети

Заголовок раздела «Подключитесь из внешней сети»
  • Веб-консоль
  • MWS CLI
  • API

  1. В веб-консоли выберите нужный проект.

  2. Для сети, к которой подключен кластер, добавьте правило файрвола для входящего трафика:

    • источник трафика — IP-адрес клиента;
    • назначение трафика — внутренний IP-адрес ресурса;
    • протокол и порт — TCP:8081.

  3. В списке сервисов выберите Managed Kafka.

  4. Нажмите на имя нужного кластера.

  5. Перейдите на вкладку Сети и затем на вкладку Реестр схем.

  6. Сохраните любой адрес реестра схем из блока Внешнее подключение. Адреса находятся в столбце URL.

  7. Перейдите на вкладку Пользователи.

  8. В списке пользователей найдите и сохраните имя нужного пользователя.

  9. Задайте переменные окружения:

    bash
    export SCHEMA_REGISTRY_URL="<адрес реестра схем>"
    export USERNAME="<имя пользователя>"
    export PASSWORD="<пароль>"

2. Зарегистрируйте первую схему

Заголовок раздела «2. Зарегистрируйте первую схему»

  1. Скачайте по прямой ссылке сертификат шифрования. Он сохранится в файле с именем mws-root-ca.crt.

  2. Зарегистрируйте схему, которая описывает структуру данных, которые будут передаваться в топик:

    bash
    curl -X POST "$SCHEMA_REGISTRY_URL/subjects/users-value/versions" \
         --cacert ~/mws-root-ca.crt \
         -u "$USERNAME:$PASSWORD" \
         -H "Content-Type: application/json" \
         -d '{"schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"id\", \"type\": \"int\"}]}"}'

    Здесь:

    • "type": "record" — структура данных (запись);
    • "name": "User" — имя схемы User;
    • "fields" — список полей схемы;
    • "name": "id" — поле с именем id;
    • "type": "int" — тип поля целочисленный.

    Если схема зарегистрирована успешно, в ответе вы получите JSON с информацией о версии схемы.

    Успешное выполнение запроса означает успешное подключение.