Yandex.Cloud
  • Сервисы
  • Почему Yandex.Cloud
  • Сообщество
  • Решения
  • Тарифы
  • Документация
  • Связаться с нами
Подключиться
Yandex Managed Service for Apache Kafka®
  • Начало работы
  • Пошаговые инструкции
    • Все инструкции
    • Информация об имеющихся кластерах
    • Создание кластера
    • Подключение к кластеру
    • Остановка и запуск кластера
    • Изменение настроек кластера
    • Управление хостами Apache Kafka®
    • Работа с топиками и разделами
    • Управление учетными записями Kafka
    • Удаление кластера
  • Сценарии использования
    • Поставка данных в Managed Service for ClickHouse
  • Концепции
    • Взаимосвязь ресурсов сервиса
    • Топики и разделы
    • Брокеры
    • Производители и потребители
    • Классы хостов
    • Сеть в Managed Service for Apache Kafka®
    • Квоты и лимиты
    • Типы хранилища
    • Настройки Apache Kafka®
  • Управление доступом
  • Правила тарификации
  • Справочник API
    • Аутентификация в API
    • gRPC
      • Обзор
      • ClusterService
      • OperationService
      • ResourcePresetService
      • TopicService
      • UserService
      • OperationService
    • REST
      • Обзор
      • Cluster
        • Обзор
        • create
        • delete
        • get
        • list
        • listHosts
        • listLogs
        • listOperations
        • move
        • start
        • stop
        • streamLogs
        • update
      • Operation
        • Обзор
        • get
      • ResourcePreset
        • Обзор
        • get
        • list
      • Topic
        • Обзор
        • create
        • delete
        • get
        • list
        • update
      • User
        • Обзор
        • create
        • delete
        • get
        • grantPermission
        • list
        • revokePermission
        • update
  • Вопросы и ответы
  1. Пошаговые инструкции
  2. Работа с топиками и разделами

Работа с топиками и разделами

  • Создать топик
  • Изменить настройки топика
  • Удалить топик
  • Получить список топиков в кластере
  • Получить детальную информацию о топике

В кластере Managed Service for Apache Kafka® вы можете:

  • Создать топик и разделы для него.
  • Изменить настройки топика и его разделов.
  • Удалить топик.
  • Получить список топиков в кластере.
  • Получить детальную информацию о топике.

Создать топик

Консоль управления
CLI
API

Чтобы создать топик, выполните следующие действия:

  1. Перейдите на страницу каталога и выберите сервис Managed Service for Apache Kafka®.
  2. Нажмите на имя нужного кластера и перейдите на вкладку Топики.
  3. Нажмите кнопку Создать топик.
  4. В блоке Базовые параметры задайте базовые параметры топика:
    • Имя топика (должно быть уникально в пределах кластера Apache Kafka®).
    • Количество разделов в топике.
    • Фактор репликации. Значение этого параметра не должно превышать количество брокеров в кластере. Минимальное значение: 1. Значение по умолчанию:
      • для кластера из одного или двух брокеров: 1;
      • для кластера с тремя и более брокерами: 3.
  5. В блоке Настройки топика задайте настройки топика.
  6. Нажмите кнопку Создать.

Если у вас еще нет интерфейса командной строки Yandex.Cloud, установите и инициализируйте его.

По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

Чтобы создать топик:

  1. Посмотрите описание команды CLI для создания топиков:

    yc managed-kafka topic create --help
    
  2. Создайте топик:

    yc managed-kafka topic create <имя топика> \
       --cluster-name <имя кластера> \
       --partitions <количество разделов> \
       --replication-factor <фактор репликации>
    

    При необходимости здесь же задайте настройки топика.

Воспользуйтесь методом API create и передайте в запросе:

  • Идентификатор кластера, в котором нужно создать топик, в параметре clusterId. Чтобы узнать идентификатор, получите список кластеров в каталоге.
  • Настройки топика в параметре topicSpec.

Изменить настройки топика

Важно

Количество разделов в топике Apache Kafka® допустимо изменять только в сторону увеличения.

Консоль управления
CLI
API

Чтобы изменить настройки топика, выполните следующие действия:

  1. Перейдите на страницу каталога и выберите сервис Managed Service for Apache Kafka®.
  2. Нажмите на имя нужного кластера, затем выберите вкладку Топики.
  3. Нажмите значок для нужного топика и выберите пункт Редактировать.
  4. Измените базовые параметры топика:
    • Количество разделов в топике.
    • Фактор репликации. Значение этого параметра не должно превышать количество брокеров в кластере. Минимальное значение: 1. Значение по умолчанию:
      • для кластера из одного или двух брокеров: 1;
      • для кластера с тремя и более брокерами: 3.
  5. Измените дополнительные настройки топика.
  6. Нажмите кнопку Сохранить.

Если у вас еще нет интерфейса командной строки Yandex.Cloud, установите и инициализируйте его.

По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

Чтобы изменить настройки топика:

  1. Посмотрите описание команды CLI для изменения топиков:

    yc managed-kafka topic update --help
    
  2. Измените настройки топика:

    yc managed-kafka topic update <имя топика> \
    --cluster-name <имя кластера> \
    --partitions <количество разделов> \
    --replication-factor <фактор репликации>
    

Воспользуйтесь методом API update и передайте в запросе:

  • Идентификатор кластера, в котором находится топик, в параметре clusterId. Чтобы узнать идентификатор, получите список кластеров в каталоге.
  • Имя топика в параметре topicName. Чтобы узнать имя, получите список топиков в кластере.
  • Список настроек, которые необходимо изменить, в параметре updateMask (одной строкой через запятую). Если не задать этот параметр, метод API сбросит на значения по умолчанию все настройки топика, которые не были явно указаны в запросе.
  • Новые значения настроек топика в параметре topicSpec.

Удалить топик

Примечание

Выданные учетной записи права на доступ к топику сохраняются даже после удаления топика. Вы можете либо отозвать эти права доступа, либо оставить. В последнем случае вы можете создать топик с тем же именем и работать с ним без переназначения прав учетной записи.

Консоль управления
CLI
API

Чтобы удалить топик, выполните следующие действия:

  1. Перейдите на страницу каталога и выберите сервис Managed Service for Apache Kafka®.
  2. Нажмите на имя нужного кластера и перейдите на вкладку Топики.
  3. Нажмите значок для нужного топика и выберите пункт Удалить топик.
  4. Подтвердите удаление топика и нажмите кнопку Удалить.

Если у вас еще нет интерфейса командной строки Yandex.Cloud, установите и инициализируйте его.

По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

Чтобы удалить топик:

  1. Посмотрите описание команды CLI для изменения топиков:

    yc managed-kafka topic delete --help
    
  2. Удалите топик:

    yc managed-kafka topic delete <имя топика> --cluster-name <имя кластера>
    

Воспользуйтесь методом API delete и передайте в запросе:

  • Идентификатор кластера, в котором находится топик, в параметре clusterId. Чтобы узнать идентификатор, получите список кластеров в каталоге.
  • Имя топика в параметре topicName. Чтобы узнать имя, получите список топиков в кластере.

Получить список топиков в кластере

Консоль управления
CLI
API

Чтобы получить список топиков, выполните следующие действия:

  1. Перейдите на страницу каталога и выберите сервис Managed Service for Apache Kafka®.
  2. Нажмите на имя нужного кластера и перейдите на вкладку Топики.

Если у вас еще нет интерфейса командной строки Yandex.Cloud, установите и инициализируйте его.

По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

Чтобы получить список топиков, выполните следующую команду:

yc managed-kafka topic list --cluster-name <имя кластера>

Воспользуйтесь методом API list: передайте значение идентификатора требуемого кластера в параметре clusterId запроса.

Чтобы узнать идентификатор кластера, получите список кластеров в каталоге.

Получить детальную информацию о топике

Консоль управления
CLI
API

Чтобы получить детальную информацию о топике, выполните следующие действия:

  1. Перейдите на страницу каталога и выберите сервис Managed Service for Apache Kafka®.
  2. Нажмите на имя нужного кластера и перейдите на вкладку Топики.
  3. Нажмите на имя нужного топика.

Если у вас еще нет интерфейса командной строки Yandex.Cloud, установите и инициализируйте его.

По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

Чтобы получить детальную информацию о топике, выполните следующую команду:

yc managed-kafka topic get <имя топика> --cluster-name <имя кластера>

Чтобы получить детальную информацию о топике, воспользуйтесь методом API get и передайте в запросе:

  • Идентификатор кластера, в котором находится топик, в параметре clusterId. Чтобы узнать идентификатор, получите список кластеров в каталоге.
  • Имя топика в параметре topicName. Чтобы узнать имя, получите список топиков в кластере.
В этой статье:
  • Создать топик
  • Изменить настройки топика
  • Удалить топик
  • Получить список топиков в кластере
  • Получить детальную информацию о топике
Language / Region
Вакансии
Политика конфиденциальности
Условия использования
Брендбук
© 2021 ООО «Яндекс.Облако»