如何在无根本原因的Akka持久性中调试JournalFailureException

Question

我正在试着调试下面的错误信息，由于错误不是打印出来的根本原因，所以很难调试这里的问题是什么。我尝试改变超时，但问题似乎没有恢复。

  Supervisor StopSupervisor saw failure: Exception during recovery. Last known sequence number [0]. PersistenceId [first], due to: Replay timed out, didn't get event within [60000 milliseconds], highest sequence number seen [0]
akka.persistence.typed.internal.JournalFailureException: Exception during recovery. Last known sequence number [0]. PersistenceId [first], due to: Replay timed out, didn't get event within [60000 milliseconds], highest sequence number seen [0]
    at akka.persistence.typed.internal.ReplayingEvents.onRecoveryFailure(ReplayingEvents.scala:263)

2020-11-20 12:21:55,999 WAR Persistence               No default snapshot store configured! To configure a default snapshot-store plugin set the `akka.persistence.snapshot-store.plugin` key. For details see 'reference.conf'
2020-11-20 12:21:56,070 WAR HikariConfig              slick.db - using dataSourceClassName and ignoring jdbcUrl.
2020-11-20 12:21:56,073 INF HikariDataSource          slick.db - Starting...
2020-11-20 12:21:56,109 INF HikariDataSource          slick.db - Start completed.

下面是我的application.conf

akka {
  loglevel = DEBUG

  persistence {
    journal.plugin = "jdbc-journal"
    snapshot-store.plugin = "jdbc-snapshot-store"
  }
}

jdbc-journal {
  slick = ${slick}
}

jdbc-snapshot-store {
  slick = ${slick}
}

jdbc-read-journal {
  slick = ${slick}
}


slick {
  profile = "slick.jdbc.MySQLProfile$"
  db {
    dataSourceClass = "slick.jdbc.DriverDataSource"
    driver = "com.mysql.cj.jdbc.Driver"
    url = "jdbc:mysql://localhost:3306/"
    user = nilu
    password = "password"
  }
}

Answer 1

使用OnPersistFailure方法。如果持久化失败，则调用此方法。演员将会弯腰驼背。最佳实践是在一段时间后再次启动actor并使用Backoff supervisor。

并使用OnPersistRejected方法。如果日记未能持久化事件，则调用此方法。演员恢复演出。（参考资料）

class MyPersistentActor extends PersistentActor with ActorLogging {
    override def persistenceId: String = ???
    override def receiveCommand: Receive = ???
    override def receiveRecover: Receive = ???

    override def onPersistFailure(cause: Throwable, event: Any, seqNr: Long): Unit = {
      log.error(s"fail to persist $event because of: $cause")
      super.onPersistFailure(cause, event, seqNr)
    }

    override def onPersistRejected(cause: Throwable, event: Any, seqNr: Long): Unit = {
      log.error(s"persist rejected for $event because of: $cause")
      super.onPersistRejected(cause, event, seqNr)
    }
  }