Got this error that I can’t figure out, maybe you guys can help. I have a 3 instance cluster, with each instance running EventStore and my app, using JVM client. ExtIp for each store is 127.0.0.1 (app is expected to connect to localhost and let EventStore do the clustering part), and ports are all defaults.
When the app starts up and does a catchup from beginning the subscription immediately terminates with:
ERROR eventstore.SubscriptionActor - eventstore.CommandNotExpectedException: Expected: ReadAllEventsCompleted, actual: NotHandled(NotMaster(MasterInfo(/127.0.0.1:1113,/127.0.0.1:2113,None)))
Code to start the subscription:
ActorSystem system = ...; final ActorRef connection = **...**; final ActorRef observerActor = system.actorOf( SubscriptionObserverActor.props(observer, scala.reflect.ClassTag$.MODULE$.apply(IndexedEvent.class))); Option<Position> currentOptionalPosition = Option.apply( null ); final ActorRef subscription = system.actorOf( SubscriptionActor.props(connection, observerActor, currentOptionalPosition, false, Option.empty(), 10)); this.subscription = ActorCloseable.apply(observerActor);
Looking into the EventStore log the cluster has formed, one master and two slaves, no errors.
Any idea what might be wrong here? Is there any issue with using ExtIp as 127.0.0.1?