This codebase shows how to implement complex event process (CEP) using AKKA and Esper engine. It uses following tech stack Domain driven design, AKKA, AKKA persistence for event sourcing using Cassandra as the store, AKKA cluster, AKKA cluster sharding Spring boot & ESPER open source CEP engine. It also makes writing test cases a breeze using in memory persistence store and spring boot.
There is another repository that implements the same concept using Apache Flink.
Detail documentation coming soon.