lhotari commented on issue #10832: URL: https://github.com/apache/pulsar/issues/10832#issuecomment-856697243
> My question is, is the above solution is fine to use? If you don't care if message sending fails, it's fine to do so. If you want to ensure the delivery of sent messages, you cannot ignore the CompletableFuture<MessageId> instances returned from `sendAsync`. 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. -- 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]
