Creates an Akka Streams stage that writes input
DurableEvents to eventLog
and emits the written DurableEvents.
Creates an Akka Streams stage that writes input
DurableEvents to eventLog
and emits the written DurableEvents. The input DurableEvent's emitterId
is set to this writer's id
. The processId
, localLogId
, localSequenceNr
and systemTimestamp
are set by
eventLog
. The event log also updates the local time of vectorTimestamp
. All other input DurableEvent
fields are written to the event log without modification. Behavior of the writer can be configured with:
eventuate.log.write-batch-size
. Maximum size of DurableEvent batches written to the event log. Events
are batched (with Flow.batch) if they are produced faster than this writer can write events.eventuate.log.write-timeout
. Timeout for writing events to the event log. A write timeout or another write
failure causes this stage to fail.
global unique writer id.
target event log.
Stream-based alternative to EventsourcedActor.