cloudflow
cloudflow copied to clipboard
lightbend
Example: Use Akka Persistence/Event Sourcing in an Akka Streamlet
Akka Streamlets have access to all of Akka's power. Let's add an example of how Akka Persistence can be used to get access to Event Sourcing with Akka Persistence.
The example should show some Cassandra-compatible database as storage backend. The user would be responsible for setting it up correctly in the Kubernetes cluster.
A good extension to this is showing it in clustered streamlets with Akka Cluster sharding.
Sorry got completely swamped with end of quarter work. It is basically done but I want to fix the readme. I will have it out of WIP status by the end of the week
Cool no worries Nolan was just curious!
On Mon, 12 Oct 2020 at 21:33, Nolan Grace [email protected] wrote:
Sorry got completely swamped with end of quarter work. It is basically done but I want to fix the readme. I will have it out of WIP status by the end of the week
— You are receiving this because you commented.
Reply to this email directly, view it on GitHub https://github.com/lightbend/cloudflow/issues/664#issuecomment-707306801, or unsubscribe https://github.com/notifications/unsubscribe-auth/AABGGCIHQOGWIN7IDPHC2D3SKNK2DANCNFSM4QLYSY2Q .
-- Cloudflow Tech Lead, Lightbend, Inc. [email protected] [email protected] @RayRoestenburg https://twitter.com/RayRoestenburg
Yeah, the Pull request #668 is waiting to be reviewed whenever you have the time.
@RayRoestenburg , @nolangrace : gentlemen, please advise if this branch is supposed to the merge-able. https://github.com/nolangrace/cloudflow/tree/akka-cqrs-sample/examples/shopping-cart-cqrs
@SemanticBeeng This was from quite some time ago. It might need some minor changes to work with Cloudflow 2.1.2, feel free to try this out?
I can say the concepts in there around using Akka projections to treat the akka journal as the stream of event to the streamlet outlet should work but when it came to merging this as an official example we would have also needed documentation on running cassandra or some kind of database in k8s which is why work on that halted