Query Plugin

It implements the following Persistence Queries:

  • eventsByPersistenceId, currentEventsByPersistenceId
  • eventsByTag, currentEventsByTag
  • persistenceIds, currentPersistenceIds

See API details in CassandraReadJournalCassandraReadJournal and eventsByTag documentation.

Persistence Query usage example to obtain a stream with all events tagged with “someTag” with Persistence Query:

val queries = PersistenceQuery(system).readJournalFor[CassandraReadJournal](CassandraReadJournal.Identifier)
queries.eventsByTag("someTag", Offset.noOffset)


The default settings can be changed with the configuration properties defined in reference.conf.

Query configuration is under akka.persistence.cassandra.query.

Events by tag configuration is under akka.persistence.cassandra.events-by-tag and shared by journal and query.

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.