rfcs
rfcs copied to clipboard
RFC: decouple sink and checkpoint
We had a meeting last Friday. Here is some summaries:
- For a quick and simple implementation, we can implement a log store via kv interface first.
- Sinks can asynchronously consume and commit the data. Only the unconsumed data will be flushed to persistent storage for consistency of checkpoint. Sink can report consume progress to help deleting the consumed data.
Is this finished (and can be merged)?