Hi, I need to use a custom serializer for Avro in Akka Persistence for certain classes. I created the serializer and registered it for a set of events in some of the Persistent classes. However, prior to those Persistent actors get called, a set of Persistent actors that don't use the Serializer get called first. At that point they fail recovery (even though the journal is empty) with the following error:
[ERROR] [06/23/2015 16:18:17.974] [application-akka.actor.default-dispatcher-21] [akka://application/user/sharding/projectListingActorCoordinator/singleton/coordinator] Processor killed after recovery failure (persistent id = [/user/sharding/projectListingActorCoordinator/singleton/coordinator]). To avoid killing processors on recovery failure, a processor must handle RecoveryFailure messages. RecoveryFailure was caused by: java.lang.IllegalArgumentException: empty broker list (akka.actor.ActorKilledException) Strangely, I did add a match for RecoveryFailure in the ProjectListingActor, but I still get the same error. Again, ProjectListingActor does not use the custom serialization. So my questions are: 1. What is " empty broker list"? 2. Does someone have an example of custom serialization with Akka Persistence working? Thanks, Chanan -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
