Re: [akka-user] Persistence Query and Sharding

Cool! Are we talking in the order of seconds here? Is it dependent on polling with an adjustable interval? There’s different modes: https://github.com/akka/akka-persistence-cassandra/blob/v0.54/core/src/main/resources/reference.conf#L244 How does the offset parameter work with eventsByTag? The e

Re: [akka-user] Persistence Query and Sharding

Thanks for the quick reply. *Eventually* all events with the given tag. > Cool! Are we talking in the order of seconds here? Is it dependent on polling with an adjustable interval? How does the offset parameter work with eventsByTag? The example in the documentation combines eventsByTag with a

Re: [akka-user] Persistence Query and Sharding

*Eventually* all events with the given tag. Note also that that stream is infinite, unlike the “currentEventsByTag” which is finite and whatever was currently visible by that tag when it was reading. — Konrad `kto.so` Malawski Akka @ Lightbend On 1 August 2

[akka-user] Persistence Query and Sharding

Hi, I'm wondering if a persistence query running in a sharded environment sees the events from all shards, or just the "local" shards. Using the Cassandra Journal Plugin. Say I have 3 cluster shards, each (for argument's sake) running in their own VM: - shard 1 - shard 2 - shard 3 Furthermore