You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Akka PersistentActor结合Cassandra报错:未配置默认Journal插件

排查Akka PersistentActor Cassandra Journal配置错误

从你给出的报错信息和配置来看,最直接的问题是配置项拼写错误,这导致Akka无法识别你指定的Journal插件,进而抛出default journal plugin is not configured的异常。

1. 修复配置拼写错误

你的application.conf里把journal拼写成了jornal,这是核心问题:

cassandrademo{
  # 错误:jornal → 正确:journal
  akka.persistence.journal.plugin = "cassandra-journal"
  akka.persistence.snapshot-store{
    plugin = "cassandra-snapshot-store"
  }
}

修正后,Akka就能正确读取你指定的Cassandra Journal插件配置了。

2. 额外检查项

除了拼写错误,还有几个点需要确认,避免后续出现其他问题:

  • 依赖是否正确引入:确保你的项目中已经添加了Akka Persistence Cassandra的依赖,比如在sbt中:
    libraryDependencies += "com.typesafe.akka" %% "akka-persistence-cassandra" % "1.0.6" // 版本请匹配你的Akka版本
    
  • Cassandra服务状态:确认你的Cassandra集群已经启动并正常运行,Akka需要能连接到Cassandra实例。
  • Actor实现正确性:检查你的LocalStoreActor是否正确继承了PersistentActor,并实现了必要的方法(比如receiveCommand、receiveRecover),虽然当前报错是配置问题,但错误的Actor实现也可能导致后续异常。

3. 关于死信的说明

你看到的死信提示是因为LocalStoreActor在初始化时就抛出了异常,导致Actor意外终止,后续发送的"hello world"和"print"消息无法被处理,所以变成了死信。修复配置问题后,Actor能正常初始化,死信问题也会随之消失。

内容的提问来源于stack exchange,提问作者user9116815

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.05.07 14:57:39