Thank you very much, I will add these points to the document 1 Now the persistence of ack is also asynchronous, not every ack will be persisted immediately, and the lost part will be re-consumed. When the entry is successfully written but the marker fails to be written, we will consider the whole to be a failure and will continue to look forward until we find a usable marker. If the data found before is not upgraded, because our new type of entry will have a mark, we will restore it according to the existing old logic.
2 We only copy the entry in the marker, other entries will not be copied. It's useless even if copied On 2021/01/18 06:16:03, Sijie Guo <g...@gmail.com> wrote: > Hi Lin,> > > Thanks you and Penghui for drafting this! We have seen a lot of pain points> > of `managedLedgerMaxUnackedRangesToPersist` when enabling delayed messages.> > Glad that you and Penghui are spending time on resolving this!> > > Overall the proposal looks good. But I have a couple of questions about the> > proposal.> > > 1. What happens if the broker fails to write the entry marker? For example,> > at t0, the broker flushes dirty pages and successfully writes an entry> > marker. At t1, the broker tries to flushes dirty pages but failed to write> > the new entry marker. How can you recover the entry marker?> > > 2. When a broker crashes and recovers the managed ledger, the cursor> > ledger is not writable anymore. Are you going to create a new cursor ledger> > and copy all the entries from the old cursor ledger to the new one?> > > It would be good if you can clarify these two questions.> > > - Sijie> > > On Sun, Jan 17, 2021 at 9:48 PM linlin <li...@apache.org> wrote:> > > > Hi, community:> > > Recently we encountered some problems when using individual> > > acknowledgments, such as:> > > when the amount of acknowledgment is large, entry writing fails; a large> > > amount of cache causes OOM, etc.> > > So I drafted a PIP in `> > >> > > https://docs.google.com/document/d/1uQtyb8t6X04v2vrSrdGWLFkuCkBcGYZbqK8XsVJ4qkU/edit?usp=sharing`> > > < https://docs.google.com/document/d/1uQtyb8t6X04v2vrSrdGWLFkuCkBcGYZbqK8XsVJ4qkU/edit?usp=sharing>> > > ,> > > any voice is welcomed.> > >> >
