我正在考虑使用CQRS的Akka持久性 . 在我的写作方面,我有像这样的实体

case class Evt(data:String)

我的持久代码看起来像

persist(Evt(s"${data}"))

所有工作都在写作方面 .

我正在使用Redis journal插件 .

当我尝试读取Read端的日志条目时,它会查找WriteModel.Evt类并看到下面的错误

[akka.dispatch.Dispatcher] WriteModel.Evt java.lang.ClassNotFoundException: WriteModel.Evt

我是否适当地坚持了这个活动?

分享Write和Read / Aggregator端之间联系的最佳实践是什么?