rdhabalia commented on pull request #14282: URL: https://github.com/apache/pulsar/pull/14282#issuecomment-1040613078
@codelipenghui > I'm thinking can we use markDelete() for the replicator? That will be tricky and there will be a chance to lose messages. eg: replicator read 2 messages, 1st message immediately failed (due to producer-queue failure) but then second message was successful somehow. now, 1st msg's callback will rewind the cursor but if 2nd msg's callback marks-delete then the broker might delete the ledger for 1st msg. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
