我需要设计一个允许
用户可以订阅任何主题
没有定义的主题限制
控制发送到一个设备或所有设备
脱机客户端（或APN）丢弃通知时的恢复。提供一种通过休息来追赶的方法
放弃所有早于年龄t的更新。
我研究了许多不同的解决方案，比如通知中心、服务总线、事件中心。。。现在发现了Kafka，不确定这是否合适。
草稿架构
使用事件中心侦听移动设备ID注册和请求主题订阅的用户ID。。把它传给下面的雷迪斯
如果注册电话/订阅主题，请将deviceid用户ID保存到主题键。
如果向主题发送消息，则查询reddis以获取主题键，并将结果发送到fifo队列进行处理。
将上一个查询的输出通过管道传输到内置的reddis发布/订阅功能中，以警告工作者角色存在挂起的工作。
当工作人员向苹果和firebase发送通知时，将发送的通知归档到下面的一些内存存储中。
存档服务器维护已发送事件的历史记录，以便不同步设备可以以后进先出队列方式获取最新信息。
问题
您对使用这种方法来解决上述需求有何看法？
我还应该学习、研究或实验什么？