Akka Projections

In Akka Projections you process a stream of events or records from a source to a projected model or external system. Each event is associated with an offset representing the position in the stream. This offset is used for resuming the stream from that position when the projection is restarted.

Akka Projections tackles the following challenges:

  • Implement the read-side of a CQRS system.

  • Ensure reliable delivery of events to external consumers in face of network errors and system crashes.

The Implementing Microservices with Akka tutorial illustrates how to implement an Event Sourced CQRS application with Akka Projections and Akka Persistence. See for example the Section 6: Projection for queries and the Section 7: Projection publishing to Kafka steps.

Learn more