Akka Projections is intended for building systems with the CQRS pattern, and facilitate in event based service to service communication.
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.
We’re happy to release the first milestone of Akka Projections, version 0.1. The API is still under development and will change for upcoming milestones. Feedback, bug reports and feature requests are welcome as issues in akka-projection/issues.
Highlights of the release:
- Core structure of Projections
- Offset storage in Cassandra
- Offset storage in relational DB with Slick
- Source provider for events from Akka Persistence (
- Source provider for messages from Kafka
- Running of Projections with
- Restart and recovery when errors occur
- TestKit for Projections
The documentation can be found at https://doc.akka.io/docs/akka-projection/current/.
A total of 30 issues were closed in this release. The complete list can be found on the 0.1 milestone on github.
For this release we had the help of 5 committers – thank you all very much!
commits added removed 47 5107 1227 Renato Cavalcanti 43 6835 930 Patrik Nordwall 9 332 38 Enno 6 1014 190 Sean Glover 1 11 11 Christopher Batey
The Akka core team is employed by Lightbend. If you’re looking to take your Akka systems to the next level, let’s set up a time to discuss our enterprise-grade expert support, self-paced education courses, and technology enhancements that help you manage, monitor and secure your Akka systems - from development to production.
– The Akka Team