krasserm/akka-persistence-kafka

Abstract method error

abdulrahman86 opened this issue · 5 comments

abdulrahman86 commented

Hi,

I am getting this error when trying to use akka-persistence-kafka.

Attaching my pom file.

This is the error I get.

java.lang.AbstractMethodError: akka.persistence.kafka.journal.KafkaJournal.akka$persistence$journal$WriteJournalBase$setter$persistence_$eq(Lakka/persistence/Persistence;)V
at akka.persistence.journal.WriteJournalBase$class.$init$(WriteJournalBase.scala:15)
at akka.persistence.kafka.journal.KafkaJournal.(KafkaJournal.scala:22)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:422)
at java.lang.Class.newInstance(Class.java:442)
at akka.util.Reflect$.instantiate(Reflect.scala:45)
at akka.actor.NoArgsReflectConstructor.produce(Props.scala:361)
at akka.actor.Props.newActor(Props.scala:252)
at akka.actor.ActorCell.newActor(ActorCell.scala:552)
at akka.actor.ActorCell.create(ActorCell.scala:578)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

Please help, sort of need this urgently

pom.txt

krasserm commented

This plugin doesn't work with Akka 2.4 yet. Put Akka 2.3 on your classpath.

abdulrahman86 commented

I dont see 2.3 for akka persistence on maven central. is that even available? or you mean 2.3 just for akka actors

abdulrahman86 commented

Thanks so much! So that error went away but now I get this.

akka.actor.InvalidActorNameException: actor name [snapshot-store] is not unique!

Attaching file for my persistent actor

actor.txt

Also attaching my app.conf file

application-conf.txt

krasserm commented

Does adding akka.persistence.snapshot-store.plugin = "kafka-snapshot-store" to your application config help?