Skip to content

Задача 008: Поддержка нескольких брокеров (RabbitMQ и Kafka)

Приоритет: Высокий Статус: Запланировано Категория: Связность / Масштабируемость


🎯 Цель

Расширить инфраструктуру Event-Driven, добавив поддержку брокеров сообщений корпоративного уровня, сохраняя при этом единый и удобный для разработчика API.

🛠 Особенности

  1. Унифицированный роутер: Абстрактный EventRouter, который работает идентично для Redis, RabbitMQ и Kafka.
  2. Адаптер RabbitMQ: Реализация на базе aio-pika с поддержкой Exchange и Queues.
  3. Адаптер Kafka: Реализация на базе aiokafka для высокопроизводительного стриминга.
  4. Декларативный синтаксис: Декораторы @rabbit_router.message("topic.event").

⬅️ Назад к Roadmap