I am using Akka Persistence and Persistence Query with Eventstore. In order to built read models I need to subscribe to events for each persistenceId. It means, that I need to create:
- as many subscriptions as persistenceIds - the question is what about performance if I will have 1 milion persistenceIds?
- projection for selected events and subscribe to this stream?
- subscription for all events from system and filter it out on app level?
What will be the best approach in order to keep as best performance of Eventstore as it is possible?