Finite state machines with Akka
codurance.com
Finite state machines with Akka
1–9 of 9 posts
Re: Finite state machines with Akka
#2What about Kafka's at-least-once semantics ?
Is that being dealt with ?
Re: Finite state machines with Akka
#3Worth noting that Erlang also has a new gen_statem in R19 coming in June. It looks like a big upgrade to gen_fsm!
Re: Finite state machines with Akka
#4What about Kafka's at-least-once semantics ? Is that being dealt with ?
Your question is hard to understand.
https://kafka.apache.org/08/design.html
"So effectively Kafka guarantees at-least-once delivery by default ...."
Edit: Downvote if you want. I was trying to help you.
Re: Finite state machines with Akka
#5Worth noting that Erlang also has a new gen_statem in R19 coming in June. It looks like a big upgrade to gen_fsm!
Not only that but ssh protocol in R19 will be implemented as a gen_statem, providing a real life usage example for it.
I also liked that Ericsson engaged with the community and considered input and updated code accordingly as they worked on it.
You can see the whole process and discussion in:
Re: Finite state machines with Akka
#6Worth noting that Erlang also has a new gen_statem in R19 coming in June. It looks like a big upgrade to gen_fsm!
Not only that but ssh protocol in R19 will be implemented as a gen_statem, providing a real life usage example for it. I also liked that Ericsson engaged with the community and considered input and updated code accordingly as they worked on it. You can see the whole process and discussion in: https://github.com/erlang/otp/pull/960
Awesome, I'll definitely have a play with the :ssh module then, even if only from the Elixir side of the fence.
Just been to ElixirConf here in Europe and was super impressed with Erlang Solutions guys and the general quality of the Erlang and Elixir people. Lots of interesting chats!
:-)
Re: Finite state machines with Akka
#7What about Kafka's at-least-once semantics ? Is that being dealt with ?
Your question is hard to understand. https://kafka.apache.org/08/design.html "So effectively Kafka guarantees at-least-once delivery by default ...." Edit: Downvote if you want. I was trying to help you.
GP asked how this system deals with Kafka's at least once semantics. Pointing out that Kafka has at least once semantics is redundant.
What GP was asking: what happens if Kafka delivers the "item added" event twice, but the "item deleted" event only once? Do you end up with an invalid/unrecoverable state?
Re: Finite state machines with Akka
#8What about Kafka's at-least-once semantics ? Is that being dealt with ?
Disclaimer: I'm the author of the post.
In this particular example, both events (item_reported and item_deleted) end up in destructive actions identified by unique id. That idempotency makes safe working with Kafka's at-least-once semantics. You can see that it's safe to execute several times this line of code:
val newItemsToBeDeleted = items.filterNot(_ == item)Re: Finite state machines with Akka
#9Akka is good, the only thing I don't like is that with actors sometimes type safety is lost, or at least takes some effort to enforce at compile time.