The following will describe the key aspects of the processing logic. While the cluster setup is based on akka-cluster with node-discovery (akka-discovery), processing logic mainly consists on processing / distribution / expectation logic added on top where batch processing is definable via akka streams, allowing flexible processing topologies. The processing definition is described in the ActorRunnable class, providing the RunnableGraph to execute on single worker nodes.