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

С помощью быстрого старта вы создадите кластер 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

Что дальше

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

Была ли статья полезной ?
Предыдущая статья
Что нового
Следующая статья
Инструкции
/ DOCS
Evolution