leiless edited a comment on issue #10832:
URL: https://github.com/apache/pulsar/issues/10832#issuecomment-858341525
Code example
```java
List> sendFutureList =
Lists.newArrayList();
for (int i = 0; i < numMsgs; i++) {
byte[] message = ("msg-" + i)
leiless edited a comment on issue #10832:
URL: https://github.com/apache/pulsar/issues/10832#issuecomment-856694634
@lhotari, many thanks for your reply.
For the
[`flush()`](https://pulsar.apache.org/api/client/2.7.0-SNAPSHOT/org/apache/pulsar/client/api/Producer.html#flush--)
metho
leiless edited a comment 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
leiless edited a comment on issue #10832:
URL: https://github.com/apache/pulsar/issues/10832#issuecomment-856694634
@lhotari, many thanks for your reply.
For the
[`flush()`](https://pulsar.apache.org/api/client/2.7.0-SNAPSHOT/org/apache/pulsar/client/api/Producer.html#flush--)
metho
leiless edited a comment on issue #10832:
URL: https://github.com/apache/pulsar/issues/10832#issuecomment-856694634
@lhotari, many thanks for your reply.
For the
[`flush()`](https://pulsar.apache.org/api/client/2.7.0-SNAPSHOT/org/apache/pulsar/client/api/Producer.html#flush--)
metho
leiless edited a comment on issue #10832:
URL: https://github.com/apache/pulsar/issues/10832#issuecomment-855166878
Instead of `fsync(2)` per message manner, I pursuing `fsync(2)` in batch(as
a whole).
Explicitly, `fsync(2)` for the last msg in a list.
Which enforces previous messages
