примеру, есть сервисы, которые шлют сообщения в один топик, а множество консумеров незамедлительно получают оповещения с данным сообщением. Причем само сообщение персистиь не надо, а отправлять только активным в данный момент консумерам, которые постоянно подключаются и отключаются. Строгая надёжность не требуется если консумер не ответил, то игнорировать. В идеале ещё чтобы была возможность каждому консумеру задать свой фильтр, чтобы можно было фильтровать поток сообщений на стороне сервиса, а не клиента.
вы про кафку?
nats.io
Кафка разве поддерживает динамическое изменение числа консумеров? Там же к партициям привязано.
клиент может при отключении удалять подписку - его больше ждать не будут. а вот фильтрация только клиентская, да
redis pubsub)
а вот это один из вариантов
Передавать данные через веб сокеты, построить абстракцию в форме room, channels, и хранить участников в редисе
Центрифугу можно взять
Что за центрифуга? Надеюсь не та, в которой космонавтов готовят)
https://github.com/centrifugal/centrifugo
Обсуждают сегодня