Skip to content
This repository has been archived by the owner on Jun 1, 2021. It is now read-only.

Automated progress tracking for stream-based event processing #344

Closed
krasserm opened this issue Oct 29, 2016 · 0 comments
Closed

Automated progress tracking for stream-based event processing #344

krasserm opened this issue Oct 29, 2016 · 0 comments
Assignees
@krasserm
Labels
adapter
Milestone
0.8

Comments

@krasserm
Copy link
Contributor

krasserm commented Oct 29, 2016 •
edited
Loading

Write source read progress to event processing target logs. This requires an extension to ReplicationProtocol.ReplicationWrite that should contain the read progresses from n sources. Also, a batch-oriented writeReplicationProgresses should be added to EventLogSPI.

For reading progress values, provide a ProcessingProgressSource that can be created from a source log id and a target log and that emits a single progress value (see also Source.fromFuture)

See also http://rbmhtechnology.github.io/eventuate/adapters/stream.html#event-processing-progress-tracking
@krasserm krasserm added this to the 0.8 milestone Oct 29, 2016
@krasserm krasserm self-assigned this Oct 29, 2016
@krasserm krasserm changed the title Automated progress tracking of stream-based event processing Automated progress tracking for stream-based event processing Oct 29, 2016
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees

@krasserm krasserm

Labels
adapter
Projects
None yet
Milestone
0.8
Development

No branches or pull requests
1 participant
@krasserm