search

lightbend / cloudflow

Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.
https://cloudflow.io
Apache License 2.0
321 stars 90 forks source link

Example: Use Akka Persistence/Event Sourcing in an Akka Streamlet #664

Open ennru opened 4 years ago

ennru commented 4 years ago

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.

ennru commented 4 years ago

Here we go: https://github.com/nolangrace/cloudflow-shopping-cart

nolangrace commented 4 years ago

I am happy to take this issue and create a PR

RayRoestenburg commented 4 years ago

Any update on this @nolangrace ?

nolangrace commented 4 years ago

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

RayRoestenburg commented 4 years ago

Cool no worries Nolan was just curious!

On Mon, 12 Oct 2020 at 21:33, Nolan Grace notifications@github.com 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. ray@lightbend.com raymond@lightbend.com @RayRoestenburg https://twitter.com/RayRoestenburg

https://www.lightbend.com/

RayRoestenburg commented 4 years ago

Hey @nolangrace how is this progressing, any news?

nolangrace commented 4 years ago

Yeah, the Pull request #668 is waiting to be reviewed whenever you have the time.

SemanticBeeng commented 3 years ago

@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

RayRoestenburg commented 3 years ago

@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?

nolangrace commented 3 years ago

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