Как работает связка Kafka + Redis sorted set + внешний шедулер для отложенных нотификаций?