leiless commented on issue #10832: URL: https://github.com/apache/pulsar/issues/10832#issuecomment-856702215
> One possibility is to add them to a map/list and validate that all completable futures were successfully completed as the last step, after your `flush()` step. What if an async sent message failed, and for example, say, it's the `N/2`-th message, and I retry sent this message, eventually, does the consumer still can read those messages in order? And why we need to ensure after `flush()`? you mean it flushes all backed in-memory messages safely persisted in Pulsar broker? and for those failed messages, it won't in the buffered to-be-sent list, so you have to retry for it? -- 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. For queries about this service, please contact Infrastructure at: [email protected]
