Подключение к Serverless Queue

Для работы с данными в Serverless Queue установите сетевое соединение с логическим брокером сервиса. Подключение выполняется к Kafka-совместимому эндпоинту, управляемому платформой.

Для подключения используются:

• Публичный эндпоинт queue.mwsapis.ru:9093 для доступа из интернета, VPC или Compute.
• Имя проекта в MWS Cloud Platform.
• API-ключ от сервисного аккаунта с нужными IAM-ролями.
• Протокол подключения SASL_SSL.
• Механизм аутентификации PLAIN.

В руководстве приведен пример подключения через веб-интерфейс AKHQ версии 0.26.0 и с использованием macOS или UNIX-подобных систем. Вы также можете подключаться и управлять Serverless Queue с помощью любых Kafka-совместимых решений. Например:

• инструменты управления — kafkactl⁠, Kafka CLI и другие из дистрибутива Apache Kafka;
• клиентские библиотеки — официальные и сторонние библиотеки для Java, Go, C/C++, Python и других языков.

1. В веб-консоли выберите нужный проект.
2. В списке сервисов выберите IAM → Сервисные аккаунты и нажмите кнопку Создать.
3. Введите имя сервисного аккаунта.
4. (опционально) Добавьте описание сервисного аккаунта.
5. Назначьте сервисному аккаунту нужные роли:

   • viewer — может просматривать список топиков;
   • editor — может отправлять и получать сообщения из всех топиков в проекте;
   • admin — может создавать и удалять топики.
6. Нажмите кнопку Создать.

Для созданного сервисного аккаунта создайте API-ключ и сохраните его.

1. Установите Java 17 или выше:

2. Добавьте Java в PATH:

3. Скачайте последнюю версию AKHQ⁠:

4. Создайте конфигурационный файл:

5. Запустите AKHQ:

1. В браузере перейдите по адресу http://localhost:8080.
2. Выберите подключение к нужному виртуальному кластеру.
3. Перейдите в раздел Nodes.

Если подключение выполнено успешно, в списке будет доступна информация о брокере.