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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

      Примечание

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

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

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

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

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

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

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

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

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

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

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

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

   sudo apt-get update
   
   

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

   sudo apt install -y kafkacat
   
   

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

   kafkacat -P \
            -b <внутренний_IP_брокера>:<порт_брокера> \
            -t <имя_топика> \
            -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 -C \
            -b <внутренний_IP_брокера>:<порт_брокера> \
            -t <имя_топика> \
            -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
   
   

Что дальше