How to handle bulk rejections from ES in the client side

Elastic Stack Elasticsearch
1

I am using Bulk Processor for indexing using the elastic doc.

and then using : bulkProcessor.add(new IndexRequest(indexName, type, id).source(json))

I am seeing high rejections with high bulk configs. Reducing these configs / increasing queue size is an option but will only work until some point. I want to have my back pressure and thus need to catch EsRejectedExecutionException and then implement my logic. But, i am not sure how to catch it.

Could some one help me here. I have followed links like 1 , 2 , but have not found the answer .

2

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