理解具有数据流的持久实体

事件源是一个很好的默认选择,但不是所有事情的正确解决方案。在你的情况下,这可能不是正确的方法。首先,你需要保留推文,还是直接发布给卡夫卡?

假设您需要持久化它们,那么聚合应该将验证传入命令和生成新事件所需的任何内容存储在内存中。根据您所描述的,您的聚合不需要任何数据来实现这一点,因此您的聚合不会是Twitter消息的列表,而可以是 NotUsed

另一种方法是自己直接将消息存储在卡桑德拉中,然后在完成后直接发布给卡夫卡。这将简单得多,涉及的机制更少,并且应该可以很好地扩展,只要确保您在Cassandra中明智地选择分区键列,我可能会按用户id进行分区。