Быстрый старт
С помощью быстрого старта вы создадите кластер Managed Kafka® и подключитесь к кластеру, а затем создадите топик и первое сообщение с помощью утилиты kafkacat.
Перед началом работы
Зарегистрируйтесь в личном кабинете Cloud.ru.
Если вы уже зарегистрированы, войдите под своей учетной записью.
Создайте виртуальную машину с ОС Ubuntu 22.04 в том же проекте, зоне доступности и подсети, где будет располагаться кластер Managed Kafka®.
Убедитесь, что вы можете подключиться к виртуальной машине по SSH.
Создайте кластер
Создайте кластер Managed Kafka® для начала работы.
Перейдите в раздел Evolution и выберите сервис Managed Kafka®.
На главной странице сервиса нажмите Создать кластер.
На шаге Общие параметры:
Задайте название кластера.
(Опционально) Введите описание кластера.
Выберите версию Kafka®.
ПримечаниеОбратите внимание, что после создания кластера версию продукта нельзя изменить.
Нажмите Продолжить.
На шаге Конфигурация:
Выберите режим развертывания кластера Бизнес.
Выберите зону доступности.
В блоке Вычислительный ресурс выберите флейвор с нужной комбинацией брокеров, vCPU и RAM.
В блоке Диск выберите из списка тип диска SSD и укажите размер диска.
Нажмите Продолжить.
На шаге Сетевые настройки из списка Подсеть выберите адрес подсети.
Нажмите Создать.
Процесс создания может занять 10-15 минут. Кластер готов к работе, когда его статус изменится на «Доступен».
Подключитесь к кластеру
Подключимся к кластеру Kafka® через SSH-туннель и создадим топик и сообщение с помощью утилиты kafkacat. Подробнее о работе с kafkacat читайте в официальной документации.
Подключитесь по SSH к виртуальной машине, созданной ранее в том же проекте, что и кластер Kafka®.
Чтобы обновить информацию об установленных пакетах, в терминале виртуальной машины введите команду:
sudo apt-get updateУстановите утилиту kafkacat с помощью команды:
sudo apt install -y kafkacatЗапустите команду отправки сообщения в топик:
kafkacat -b <внутренний_IP_брокера>:<порт_брокера> -t <имя_топика> -P \-X security.protocol = SASL_PLAINTEXT \-X sasl.mechanism = SCRAM-SHA-512 \-X sasl.username = "<логин_пользователя>" \-X sasl.password = "<пароль_пользователя>" \-K:Чтобы узнать внутренний IP-адрес, порт, логин и пароль, в списке кластеров нажмите на название кластера и перейдите в блок Данные для подключения.
Введите сообщение для отправки. Например, чтобы отправить несколько сообщений:
1 :foo2 :barПодробнее о формате сообщений kafkacat в официальной документации.
Чтобы завершить команду, нажмите Ctrl + D.
Чтобы посмотреть отправленное сообщение, запустите команду в отдельном терминале:
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: 1Value: fooKey: 2Value: bar% Reached end of topic <имя_топика> [ 0 ] at offset 2
Что дальше
Если вы закончили работу с примером, удалите кластер.
- Перед началом работы
- Создайте кластер
- Подключитесь к кластеру
- Что дальше