Global-scale event sourcing and event collaboration with causal consistency (This project is in maintenance mode. Only critical bugs will be fixed, but there is no more feature development.).
The DurableEventProcessor of the Akka Streams adapter should emit progress data in addition to processed DurableEvents so that applications can track processing progress in an external data store. Progress data are the source log id and the source sequence number of a processed event. Progress data from a stateful processor additionally include the current processing state (allowing applications to save state snapshots).
The
DurableEventProcessorof the Akka Streams adapter should emit progress data in addition to processedDurableEvents so that applications can track processing progress in an external data store. Progress data are the source log id and the source sequence number of a processed event. Progress data from a stateful processor additionally include the current processing state (allowing applications to save state snapshots).