Связаться с намиПодключиться

Обновление версии Apache Kafka®

Статья создана
Обновлена 31 октября 2024 г.

Вы можете обновить кластер Managed Service for Apache Kafka® до версии 3.5 или ниже. Обновление до версии 3.6 и выше не поддерживается, но можно создать кластер с одной из таких версий.

Рекомендуется обновлять версию Apache Kafka® поэтапно, без пропуска версий. Например, обновление версии с 2.8 до 3.1 выполняется в такой последовательности: 2.8 → 3.0 → 3.1.

Об обновлениях в рамках одной версии и обслуживании хостов см. в разделе Техническое обслуживание.

Перед обновлением версии

Убедитесь, что это не нарушит работу ваших приложений — изучите историю изменений Apache Kafka®.

Обновить кластер

Внимание

После обновления версии Apache Kafka® вернуть кластер к предыдущей версии невозможно.

Во время обновления топики могут быть недоступны, если их фактор репликации равен единице.

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

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

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

  1. Получите список ваших кластеров Managed Service for Apache Kafka®:

    yc managed-kafka cluster list

  2. Получите информацию о нужном кластере и проверьте версию в свойстве config.version:

    yc managed-kafka cluster get <имя_или_идентификатор_кластера>

  3. Запустите обновление Apache Kafka®:

    yc managed-kafka cluster update <имя_или_идентификатор_кластера> \
   --version=<номер_новой_версии>

  1. Откройте актуальный конфигурационный файл Terraform с планом инфраструктуры.

    О том, как создать такой файл, см. в разделе Создание кластера.

  2. Добавьте в блок config нужного кластера Managed Service for Apache Kafka® поле version (версия Apache Kafka®) или измените его значение, если оно уже существует:

    resource "yandex_mdb_kafka_cluster" "<имя_кластера>" {
  ...
  config {
    version = "<версия>"
  }
}

  3. Проверьте корректность настроек.

    1. В командной строке перейдите в каталог, в котором расположены актуальные конфигурационные файлы Terraform с планом инфраструктуры.

    2. Выполните команду:

      terraform validate

      Если в файлах конфигурации есть ошибки, Terraform на них укажет.

  4. Подтвердите изменение ресурсов.

    1. Выполните команду для просмотра планируемых изменений:

      terraform plan

      Если конфигурации ресурсов описаны верно, в терминале отобразится список изменяемых ресурсов и их параметров. Это проверочный этап: ресурсы не будут изменены.

    2. Если вас устраивают планируемые изменения, внесите их:

      1. Выполните команду:

        terraform apply

      2. Подтвердите изменение ресурсов.

      3. Дождитесь завершения операции.

Подробнее см. в документации провайдера Terraform.

Ограничения по времени

Провайдер Terraform ограничивает время на выполнение всех операций с кластером Managed Service for Apache Kafka® 60 минутами.

Операции, длящиеся дольше указанного времени, прерываются.

Как изменить эти ограничения?

Добавьте к описанию кластера блок timeouts, например:

resource "yandex_mdb_kafka_cluster" "<имя_кластера>" {
  ...
  timeouts {
    create = "1h30m" # Полтора часа
    update = "2h"    # 2 часа
    delete = "30m"   # 30 минут
  }
}

Чтобы обновить кластер, воспользуйтесь методом REST API update для ресурса Cluster или вызовом gRPC API ClusterService/Update и передайте в запросе:

  • Идентификатор кластера в параметре clusterId. Его можно получить со списком кластеров в каталоге.
  • Номер версии Apache Kafka® в параметре configSpec.version.
  • Список изменяемых полей конфигурации кластера в параметре updateMask.

Важно

Метод API переопределит все параметры изменяемого объекта, которые не были явно переданы в запросе, на значения по умолчанию. Чтобы избежать этого, перечислите настройки, которые вы хотите изменить, в параметре updateMask (одной строкой через запятую).

Примеры

Допустим, нужно обновить кластер с версии 2.8 до версии 3.0.

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

    yc managed-kafka cluster list

    +----------------------+---------------+---------------------+--------+---------+
|          ID          |     NAME      |     CREATED AT      | HEALTH | STATUS  |
+----------------------+---------------+---------------------+--------+---------+
| c9q8p8j2gaih******** |    kafka35    | 2021-10-23 12:44:17 | ALIVE  | RUNNING |
+----------------------+---------------+---------------------+--------+---------+

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

    yc managed-kafka cluster get kafka35

      id: c9q8p8j2gaih********
  ...
  config:
    version: "2.8"
    ...

  3. Для обновления кластера kafka35 до версии 3.0 выполните команду:

    yc managed-kafka cluster update kafka35 --version=3.0
Предыдущая
Изменение настроек кластера
Следующая
Управление дисковым пространством