Handling ESRejections on bulk operations using transport client

Hi All,

When doing bulk indexing using transport client, if there are rejections from ES because queues are full, how do we retry these?

I tried Retry.on(EsRejectedExecutionException.class)..withSyncBackoff, but looks like it doesn't work with Transport client.

Any suggestions and if anyone can share a sample code, that would be great


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