Emit progress data with processed messages
Opened this issue · 0 comments
krasserm commented
The DurableEventProcessor
of the Akka Streams adapter should emit progress data in addition to processed DurableEvent
s 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).