我们正在进行一个项目，以建立一个分布式消息和通知系统，如gmail/whatsapp。
目前我有一些扩展和性能问题。我们的体系结构在kafa消息代理中删除消息。消息负载具有消息正文和收件人/组。然后，侦听器检查消息，然后针对收件人在数据库中创建条目。
这种在数据库中创建或插入数百万条记录的活动效率不高，而且会浪费时间，而且会根据代理中的消息堆积起来。这会导致消息的传递时间段不规则。
谁能告诉我怎么解决这个问题吗。
我一直对gmail/whatsapp的体系结构很感兴趣，他们能在多快的时间内将信息即时传递给100万用户。