我们正在开发一个项目来构建一个分布式消息和通知系统，例如 Gmail /whatsapp。
目前我有一些缩放和性能问题。我们的架构在 kafa 消息代理中丢弃消息。消息有效负载具有消息正文和收件人/组。侦听器然后检查消息，然后根据接收者进入数据库。
这种在数据库中创建插入数百万条记录的活动效率不高，而且很耗时，并且会根据代理中存在的消息堆积起来。这导致消息的不规则传递时间段。
谁能指导我如何解决这个问题。
我总是对 gmail / whatsapp 架构的原理很感兴趣，他们能够在多长时间内立即将消息传递给数以亿计的用户。