tocdepth

2

Быстрый старт

С помощью быстрого старта вы создадите кластер Managed Kafka® и подключитесь к кластеру, а затем создадите топик и первое сообщение с помощью утилиты kafkacat.

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

  1. Зарегистрируйтесь в личном кабинете Cloud.ru.

    Если вы уже зарегистрированы, войдите под своей учетной записью.

  2. Сгенерируйте SSH-ключ и загрузите его в облачный каталог.

  3. Создайте виртуальную машину с ОС Ubuntu 22.04 в том же проекте, зоне доступности и подсети, где будет располагаться кластер Managed Kafka®.

  4. Назначьте виртуальной машине публичный IP-адрес.

  5. Убедитесь, что вы можете подключиться к виртуальной машине по SSH.

Создайте кластер

Создайте кластер Managed Kafka® для начала работы.

  1. Перейдите в раздел Evolution и выберите сервис Managed Kafka®.

  2. На главной странице сервиса нажмите Создать кластер.

  3. На шаге Общие параметры:

    1. Задайте название кластера.

    2. (Опционально) Введите описание кластера.

    3. Выберите версию Kafka®.

      Примечание

      Обратите внимание, что после создания кластера версию продукта нельзя изменить.

  4. Нажмите Продолжить.

  5. На шаге Конфигурация:

    1. Выберите режим развертывания кластера Бизнес.

    2. Выберите зону доступности.

    3. В блоке Вычислительный ресурс выберите флейвор с нужной комбинацией брокеров, vCPU и RAM.

    4. В блоке Диск выберите из списка тип диска SSD и укажите размер диска.

  6. Нажмите Продолжить.

  7. На шаге Сетевые настройки из списка Подсеть выберите адрес подсети.

  8. Нажмите Создать.

Процесс создания может занять 10-15 минут. Кластер готов к работе, когда его статус изменится на «Доступен».

Подключитесь к кластеру

Подключимся к кластеру Kafka® через SSH-туннель и создадим топик и сообщение с помощью утилиты kafkacat. Подробнее о работе с kafkacat читайте в официальной документации.

  1. Подключитесь по SSH к виртуальной машине, созданной ранее в том же проекте, что и кластер Kafka®.

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

    sudo apt-get update

  3. Установите утилиту kafkacat с помощью команды:

    sudo apt install -y kafkacat

  4. Запустите команду отправки сообщения в топик:

    kafkacat -b <внутренний_IP_брокера>:<порт_брокера> -t <имя_топика> -P \
         -X security.protocol=SASL_PLAINTEXT \
         -X sasl.mechanism=SCRAM-SHA-512 \
         -X sasl.username="<логин_пользователя>" \
         -X sasl.password="<пароль_пользователя>" \
         -K:

    Чтобы узнать внутренний IP-адрес, порт, логин и пароль, в списке кластеров нажмите на название кластера и перейдите в блок Данные для подключения.

  5. Введите сообщение для отправки. Например, чтобы отправить несколько сообщений:

    1:foo
2:bar

    Подробнее о формате сообщений kafkacat в официальной документации.

  6. Чтобы завершить команду, нажмите Ctrl + D.

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

    kafkacat -b <внутренний_IP_брокера>:<порт_брокера> -t <имя_топика> -C \
         -X security.protocol=SASL_PLAINTEXT \
         -X sasl.mechanism=SCRAM-SHA-512 \
         -X sasl.username="<логин_пользователя>" \
         -X sasl.password="<пароль_пользователя>" \
         -f 'Key: %k\nValue: %s\n'

    Пример ответа:

    Key: 1
Value: foo
Key: 2
Value: bar
% Reached end of topic <имя_топика> [0] at offset 2

Что дальше

Если вы закончили работу с примером, удалите кластер.

Запустили Evolution free tier
для Dev & Test
Получить