PREVIEW

Serverless Queue

Kafka-совместимый брокер сообщений на платформе MWS Cloud Platform

Построен на бессерверной архитектуре для быстрой интеграции с вашими приложениями

В консоль Документация

Готовая инфраструктура для стриминга событий

Подключитесь к виртуальному кластеру Serverless Queue в MWS Cloud Platform и начните стриминг событий без сложной настройки инфраструктуры.

Управляйте логикой обработки сообщений по привычному протоколу Kafka.

Kafka-протокол

Используйте стандартный Kafka-протокол, знакомые библиотеки и инструменты

Надёжное хранение данных

События хранятся в Object Storage от MWS Cloud Platform в ЦОД уровня Tier III

Ускоряйте обработку при росте нагрузки

Запустите больше экземпляров приложения в группе потребителей — разделы топика распределятся между ними автоматически

Безопасность данных

Каждое приложение подключается с сервисным аккаунтом и API-ключом по защищённому соединению SASL_SSL

Архитектура сервиса

В основе Serverless Queue — бессерверная архитектура. Сообщения не привязаны к отдельным брокерам, а хранятся в распределённом хранилище. Поэтому сервис подходит для переменного трафика без предварительного резервирования инфраструктуры и ручного обслуживания кластера.

Внутри платформа сама управляет сохранением сообщений, offset’ами, consumer groups, квотами и доступом. На стороне пользователя остаётся работа с топиками и событиями через стандартный Kafka-протокол.

Как начать работу с сервисом

Активируйте сервис в своём проекте MWS Cloud Platform
Создайте сервисный аккаунт и выпустите API-ключ
Укажите эндпоинт и API-ключ в выбранном Kafka-совместимом клиенте
Создайте первый топик, подключите продюсеры, потребители и начните стриминг данных

Начать

Подключайте любой Kafka‑совместимый клиент

AKHQ

Веб‑интерфейс для просмотра и управления Kafka‑кластерами: топики, группы потребителей и сообщения

Kafka UI

Веб-интерфейс для мониторинга и управления кластерами Kafka, топиками, consumer groups и сообщениями

Kafka CLI

Стандартный набор команд Apache Kafka для администрирования, создания топиков, отправки и чтения сообщений

kafkactl

CLI-инструмент для управления Kafka из терминала: топики, группы потребителей, ACL и другие операции

kcat

Лёгкая CLI-утилита для проверки подключения, публикации и чтения сообщений из Kafka

Когда стоит выбрать
Serverless Queue?

Serverless Queue полезен, когда нужно быстро запустить потоковую обработку, а нагрузка меняется от спокойной до всплесковой. Команда фокусируется на событиях и обработчиках, а не на подготовке Kafka‑инфраструктуры

Событийная интеграция микросервисов

Асинхронный обмен между сервисами вместо синхронных вызовов: заказы, платежи, статусы, нотификации

Сбор логов и кликстрима

Единая шина для телеметрии, продуктовых событий и логов приложений с дальнейшей выгрузкой в аналитику.

Пилоты и тестовые среды

Проверить событийную архитектуру без выделенного кластера: топик создаётся за минуты и удаляется так же быстро

Буфер перед аналитикой и ML

Сглаживание пиков перед хранилищем, фичами и инференсом: потребители читают в своём темпе

Serverless Queue или выделенный кластер

Если нагрузка плавающая, а команде важнее быстро запустить сценарий, выбирайте Serverless Queue. Когда нужны выделенные ресурсы и тонкая настройка Kafka-кластера — подойдёт Managed Kafka или своя локальная инсталляция

Serverless Queue

Плавающая нагрузка, пилоты и PoC

Готовый виртуальный кластер без менеджмента инфраструктуры
Управление через Kafka-совместимые клиенты
Для плавающей нагрузки

Попробовать

Managed Kafka

Стабильный продакшен и выделенный пул ресурсов

Выделенный пул вычислительных ресурсов
Тонкая настройка инфраструктуры кластера
Для систем с высокими требованиями к задержкам

Подробнее

Локальная инсталляция Kafka

Полный контроль над кластерами, но большие затраты на эксплуатацию

Гибкое управление настройками и конфигурацией
Планирование ресурсов, обновления и мониторинг на команде эксплуатации
Меньше возможностей для масштабирования

Как получить доступ к Preview
- Войдите или зарегистрируйтесь в консоли MWS Cloud Platform
- Выберите Serverless Queue в левом меню
- На странице сервиса нажмите «Запросить доступ»
- Дождитесь письма с решением. Срок рассмотрения заявки — до 2 рабочих дней
В консоль

FAQ

Serverless Queue — Kafka-совместимый сервис, предоставляемый на инфраструктуре облака MWS Cloud Platform. Предназначен для обработки потоков сообщений в реальном времени по Kafka-совместимому протоколу. Сервис берёт на себя заботу о вычислительной инфраструктуре, необходимой для работы Kafka.

Сервис совместим с Kafka-протоколом, но отличается моделью эксплуатации: пользователю не нужно разворачивать и обслуживать брокеры. Serverless Queue подходит для событийных сценариев с плавающей нагрузкой.

Войдите в консоль MWS Cloud Platform, выберите Serverless Queue в левом меню и нажмите «Запросить доступ». Решение по заявке придёт на почту в течение 2 рабочих дней.

Нет. Для работы с топиками, сообщениями и группами потребителей используйте Kafka-совместимые клиенты и инструменты. Веб-консоль MWS Cloud Platform используется для входа, работы с проектом и IAM.

Для подключения воспользуйтесь любым удобным для вас инструментом управления Kafka: AKHQ, Kafdrop, kafkactl, Kafka CLI и т.д. Подробная инструкция по подключению есть в документации.

Сообщения хранятся в распределённом отказоустойчивом хранилище на базе MWS Object Storage. Платформа берёт на себя размещение и резервирование данных; срок хранения сообщений составляет до 10 дней.

На стадии Preview Serverless Queue не тарифицируется.

Если у вас возник вопрос по эксплуатации сервиса — обратитесь в техническую поддержку MWS Cloud Platform. Если у вас есть вопрос к разработчикам сервиса — напишите нам в открытый чат Сообщества MWS Cloud Platform.

Куда обратиться, если нужна помощь?
Если у вас возник вопрос по эксплуатации сервиса — обратитесь в техническую поддержку MWS Cloud Platform. Если у вас есть вопрос к разработчикам сервиса — напишите нам в открытый чат Сообщества MWS Cloud Platform