Связаться с экспертомПопробовать бесплатно
Создавайте контент и получайте гранты!Готовы написать своё руководство? Участвуйте в контент-программе и получайте гранты на работу с облачными сервисами!
Подробнее о программе
Проект Яндекса
© 2026 ТОО «Облачные Сервисы Казахстан»

Создание реестра схем для поставки данных в формате Debezium CDC из Apache Kafka®

Статья создана
Обновлена 16 июня 2026 г.
Открыть в Markdown

Важно

Функциональность доступна только в регионе Россия.

Вы можете создать реестр схем, чтобы отслеживать эволюцию схем для источника Apache Kafka® или Yandex Managed Service for Apache Kafka® с помощью сервиса Yandex Data Transfer. В этом руководстве отслеживается эволюция схем для источника Managed Service for Apache Kafka®.

Чтобы отследить изменение схем для источника Managed Service for Apache Kafka®:

  1. Подготовьте инфраструктуру.
  2. Создайте реестр схем.
  3. Подготовьте и запустите трансфер.

Если созданные ресурсы вам больше не нужны, удалите их.

Перед началом работы

Зарегистрируйтесь в Yandex Cloud и создайте платежный аккаунт:

  1. Перейдите в консоль управления, затем войдите в Yandex Cloud или зарегистрируйтесь.
  2. На странице Yandex Cloud Billing убедитесь, что у вас подключен платежный аккаунт, и он находится в статусе ACTIVE или TRIAL_ACTIVE. Если платежного аккаунта нет, создайте его и привяжите к нему облако.

Если у вас есть активный платежный аккаунт, вы можете создать или выбрать каталог, в котором будет работать ваша инфраструктура, на странице облака.

Подробнее об облаках и каталогах.

  • Кластер Managed Service for Apache Kafka®: использование выделенных хостам вычислительных ресурсов, объем хранилища и резервных копий (тарифы Managed Service for Apache Kafka®).
  • Каждый трансфер: использование вычислительных ресурсов и количество переданных строк данных (тарифы Data Transfer).

Подготовьте инфраструктуру

Создайте кластер Managed Service for Apache Kafka® произвольной конфигурации. Если вы планируете подключаться к хостам-брокерам из интернета, включите публичный доступ. В этом случае подключаться к ним можно только с использованием SSL-соединения.

Создайте реестр схем

  1. В консоли управления выберите каталог, в котором вы будете работать с реестром схем.
  2. Перейдите в сервис Yandex MetaData Hub.
  3. Hа панели слева выберите Schema Registry / Пространство имён.
  4. Нажмите кнопку Создать пространство имён.
  5. Укажите настройки пространства имен. После сохранения пространства имен, вы сможете использовать его идентификатор для получения URL Schema Registry: {namespace_id}.schema-registry.yandexcloud.net:443.

Подготовьте и запустите трансфер

  1. Откройте консоль управления.

  2. Перейдите в сервис Yandex Data Transfer.

  3. Создайте эндпоинт-источник Apache Kafka® со следующими настройками:

    • Тип базы данных — Apache Kafka®.

    • Тип подключения — Ручная настройка.

    • Тип инсталляции — Кластер Managed Service for Apache Kafka®.

    • В блоке Кластер Managed Service for Apache Kafka®:

      • Кластер Managed Service for Apache Kafka® — выберите созданный ранее кластер Managed Service for Apache Kafka®.
      • Аутентификация — SASL.
      • Имя пользователя и Пароль — имя и пароль пользователя в кластере Managed Service for Apache Kafka®.

    • В блоке Расширенные настройки → Правила конвертации:

      • Правила конвертации — Парсер Debezium CDC.
      • Настройки подключения к Schema Registry — On Premise Schema Registry.
      • Schema Registry URL — полученный ранее URL Schema Registry.

  4. Создайте и запустите трансфер данных.

Удалите созданные ресурсы

Примечание

Перед тем как удалить созданные ресурсы, деактивируйте трансфер.

Некоторые ресурсы платные. Удалите ресурсы, которые вы больше не будете использовать, чтобы не платить за них:

Предыдущая
Удаление субъекта
Следующая
Реестр схем