Hi. I am not sure if this is the correct place to ask this question. Please forgive me if it isn’t. I am ugrading to Akka Version 2.64 and I need to get my Akka Persistence working. Previously I was using version 0.55 and I am moving to 1.0.0-RC1.
Previous version:
“com.typesafe.akka” %% “akka-persistence-cassandra” % “0.55”
Version I am going to:
“com.typesafe.akka” %% “akka-persistence-cassandra” % “1.0.0-RC1”
I changed from sbt.version=0.13.16 to sbt.version=1.3.3
My previous application.conf contained:
akka {
persistence {
cassandra {
journal {
plugin = “cassandra-journal”
}
snapshot {
plugin = “cassandra-snapshot-store”
}
}
}
}
I am attempting to create my new application.conf, but keep getting errors. This is what it looks like: akka {
persistence {
journal {
plugin = “akka.persistence.cassandra.journal.CassandraJournal”
basic.request.timeout = 10 seconds
basic.session-keyspace = “”${OurKeyspace}""
}
snapshot {
plugin = "akka.persistence.cassandra.snapshot.CassandraSnapshotStore"
basic.request.timeout = 10 seconds
basic.session-keyspace = ""${OurKeyspaceSnapshot}""
}
}
I am not sure if I need to make any changes to reference.conf with the new version. Currently it only contains the default values and since I am using a local version of cassandra:
datastax-java-driver {
basic.contact-points = [ “127.0.0.1:9042”]
}
The error I am getting is:
timestamp=14:10:27 app_name=elkindexing env=ENVIRONMENT_IS_UNDEFINED mesos_task_id=Non-mesos-env log_level=ERROR class_name={akka.event.slf4j.Slf4jLogger$$anonfun$receive$1 $anonfun$applyOrElse$1} - message=Journal plugin [akka.persistence.cassandra.journal.CassandraJournal] configuration doesn’t exist.
akka.actor.ActorInitializationException: akka://ElkIndexingSystem/user/ElkIndexingSourceMgr/elkIndexingSourceMgmtPersistActor: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:195)
at akka.actor.ActorCell.create(ActorCell.scala:657)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:509)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:531)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:294)
at akka.dispatch.Mailbox.run(Mailbox.scala:229)
at akka.dispatch.Mailbox.exec(Mailbox.scala:242)
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
Caused by: java.lang.IllegalArgumentException: Journal plugin [akka.persistence.cassandra.journal.CassandraJournal] configuration doesn’t exist.
at akka.persistence.Persistence$.verifyPluginConfigExists(Persistence.scala:175)
at akka.persistence.Persistence.verifyJournalPluginConfigExists(Persistence.scala:275)
at akka.persistence.Persistence.defaultJournalPluginId$lzycompute(Persistence.scala:220)
at akka.persistence.Persistence.defaultJournalPluginId(Persistence.scala:217)
at akka.persistence.Persistence.journalConfigFor(Persistence.scala:327)
at akka.persistence.Eventsourced.init(Eventsourced.scala:97)
at ElkIndexingCode.CommonActorsAndTraits.ElkIndexingSourceBlockPersistentActor.(ElkIndexingSourceBlockPersistentActor.scala:24)
at ElkIndexingCode.CommonActorsAndTraits.ElkIndexingSourceManagementActor.$anonfun$InitOurSources$2(ElkIndexingSourceManagementActor.scala:105)
at akka.actor.TypedCreatorFunctionConsumer.produce(IndirectActorProducer.scala:90)
at akka.actor.Props.newActor(Props.scala:226)
at akka.actor.ActorCell.newActor(ActorCell.scala:609)
at akka.actor.ActorCell.create(ActorCell.scala:635)
… 9 common frames omitted
Thank you so much for any help!!!