Задача 008: Поддержка нескольких брокеров (RabbitMQ и Kafka)
Приоритет: Высокий Статус: Запланировано Категория: Связность / Масштабируемость
🎯 Цель
Расширить инфраструктуру Event-Driven, добавив поддержку брокеров сообщений корпоративного уровня, сохраняя при этом единый и удобный для разработчика API.
🛠 Особенности
- Унифицированный роутер: Абстрактный
EventRouter, который работает идентично для Redis, RabbitMQ и Kafka. - Адаптер RabbitMQ: Реализация на базе
aio-pikaс поддержкой Exchange и Queues. - Адаптер Kafka: Реализация на базе
aiokafkaдля высокопроизводительного стриминга. - Декларативный синтаксис: Декораторы
@rabbit_router.message("topic.event").