Now here we will share some possible designs when you use the spring boot event sourcing toolkit starter plus some remarks and action points .
What are some possible designs using the toolkit for event sourcing and CQRS services :
Apache Ignite
Spring Boot Akka Event Sourcing Starter – Part 3 – The Working Example
Now I will share a working service example of how to use the event sourcing toolkit starter in practice , in the example I will show the following:
- How to configure and use the event sourcing starter with spring boot web application
- How to implement your aggregate entity using the API of the toolkit
- How to define your entity flow using the execution flow API
- How to configure your entity
- How to configure your Akka system with spring boot
- How to call your aggregates from your service and connect that to your DDD service REST API
- How to use Google Protobuf to serialize your events instead of Java serialization
- The usage of Apache Ignite as your persistence event store with Akka persistence
- In Part 4 we sill cover the summary and possible designs plus some special remarks
Spring Boot Akka Event Sourcing Starter – Part 1
Here I am going to share a custom toolkit wrapped as a spring boot with AKKA persistence starter to act as a read made toolkit for event driven asynchronous non blocking flow API , event sourcing and CQRS implementation within spring boot services which can be part of spring cloud micro-services infrastructure . Continue reading
Spring boot with Apache Ignite fail fast distributed map reduce closures
Here we are going a cover a case need in Apache ignite , what if you want to do distributed compute jobs that do data computations or external service calls using Apache Ignite distributed closures that has map reduce nature and fail fast once of the computations fail or it has the unexpected results , how to do that ? below we are going to explain that .
Akka Persistence with Apache ignite
In this post we will share a starting project to use Apache ignite data grid an event and snapshot store to mix the benefits of the event sourcing and the data grid .
The implementation is based into the Journal plugin TCK specs provided by Akka persistence.
This is mainly using Apache ignite with akka persistence to provide journal and snapshot store by using the partitioned caches and benefit from the distributed highly available data grid features plus the nice query and data computations features in Ignite that can be used to have normalized views from the event store and do analytical jobs over them despite it is advised to keep write nodes separate from read nodes for better scalability.
Spring boot with Apache ignite persistent durable memory storage plus sql queries over ignite cache
In this post we will show how we can do the following :
- Integrate spring boot with Apache Ignite
- How to enable and use persistent durable memory feature of Apache Ignite which can persist your cache data to the file disk to survive crash or restart so you can avoid data losing.
- How to execute SQL queries over ignite caches
- How to unit test and integration test ignite with spring boot
- Simple Jenkins pipeline reference
- Code repository in GitHub : GithubRepo
Guarantee your single computation task to be finished in case of node failures/crash in apache Ignite
How to guarantee your single computation task is guaranteed to failover in case of node failures in apache Ignite ?
As you know failover support in apache ignite for computation tasks is only covered for master slave jobs where slave nodes will do computations then reduce back to the master node , and in case of any failure in slave nodes where slave jobs are executing , then it that failed slave job will fail over to another node to continue execution .
Ok what about if I need to execute just single computation task and I need to have failover guarantee due may be it is a critical task that do financial data modification or must finished task in an acceptable status (Success or Failure) , how we can do that ? it is not supported out of the box by Ignite but we can have a small design extension using Ignite APIs to cover the same , HOW ?
Code reference is hosted into my github :
https://github.com/Romeh/failover-singlejob-ignite
