Handle Failures in Bulk Processor

Elastic Stack Elasticsearch
1

Hi All

I need to handle failures and retry for failures in Bulk Processor. BulkProcessor listener has afterBulk methods. For the below method, the response provides a way to extract failures for individual items but it doesn't provide a way to get the passed request. I don't have ID at the time of sending the request. Is there any way to extract the failed request from the BulkItemResponse?

public void afterBulk(long executionId, BulkRequest request, BulkResponse response)

Thanks
Guru

2

I am still trying to figure out a way to get the failed requests, Is there a way to do it?

3

I figured out this from the java doc of getItemID.

"The numeric order of the item matching the same request order in the bulk request."