BulkProcessor.awaitClose() on returning false


if BulkProcessor.awaitClose() returns false, can I tell which messages elastic managed to index so far?
I am asking this because in my code I am waiting on bulkProcessor.awaitClose(). If it fails (timeout), i would like to retry index the messages. However, I don't want to re-index messages elastic indexed.


I guess that the listener and the method afterBulk could help here?

That what I would expect to be, but they are not invoked.
They are called in success or fail, but not if awaitClose returns false.

M'y assumption is that if the listener is not called you can assume that the documents have not been processed.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.