то там привет FULL SCAN.
С индексом должно быть не так страшно. Можно сделать отдельную табличку с таймстампами и состоянием.
> Можно в памяти воркера хранить отсортированные множества и делать вычитания,
Redis + set
> Кстати, если не NATS, то что?
Думаю, Кафка в данном случае хорошо подойдет
да, там есть SDIFF и SINTER, просто с базы неудобно выбирать все подписки которые ещё не в очереди, нужно тогда хранить <все ID> и <ID которые уже в очереди> внутри редиса
Обсуждают сегодня