Вернуться наверх

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

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

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

  • Эндпоинт:
    • queue.mwsapis.ru:9093 — публичный эндпоинт для доступа из интернета, VPC или Compute;
    • queue-int.mwsapis.ru:9093 — внутренний эндпоинт для доступа внутри MWS Cloud Platform по IPv6.
  • Имя проекта в MWS Cloud Platfrom.
  • 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. Создайте сервисный аккаунт ​

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

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

  1. В веб-консоли выберите нужный проект.
  2. В списке сервисов выберите IAM → Сервисные аккаунты.
  3. Нажмите на имя нужного сервисного аккаунта и перейдите на вкладку Ключи доступа.
  4. Нажмите кнопку Создать ключ и выберите API-ключ.
  5. Введите имя ключа.
  6. (опционально) Добавьте описание ключа.
  7. (опционально) Ограничьте срок действия ключа.
  8. Нажмите кнопку Создать.
  9. Скопируйте API-ключ и сохраните его в надежном месте. После закрытия окна API-ключ станет недоступен для просмотра.
  10. Нажмите кнопку Закрыть.

3. Установите и запустите AKHQ ​

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

    bash
    brew install openjdk@17

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

    bash
    echo 'export PATH="/opt/homebrew/opt/openjdk@17/bin:$PATH"' >> ~/.zshrc
source ~/.zshrc

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

    bash
    curl -L -o akhq.jar https://github.com/tchiotludo/akhq/releases/download/0.26.0/akhq-0.26.0-all.jar

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

    bash
    cat > application.yml << 'EOF'
akhq:
  connections:
    <имя виртуального кластера>:
      properties:
        bootstrap.servers: "queue.mwsapis.ru:9093"
        security.protocol: SASL_SSL
        sasl.mechanism: PLAIN
        sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="<имя проекта>" password="<API-ключ>";
EOF

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

    bash
    java -Dmicronaut.config.files=$HOME/application.yml -jar akhq.jar

4. Подключитесь и проверьте подключение ​

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

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