Handle retries for bulk api

akhil_reddy · August 11, 2023, 1:12pm

Hi,
I am trying to make a bulk request using BulkRequest in java. I am not finding any documentation to retry the failed requests. Is there any inbuilt functionality in the java client api to handle retries or do I need to handle it the code. I am referring this page

Thank you

dadoonet · August 12, 2023, 9:20am

Have a look at this.

github.com

dadoonet/elasticsearch-java-client-demo/blob/be89f7cc7530cebfaeadc7c5e9bf109c71ee4caa/src/test/java/fr/pilato/test/elasticsearch/hlclient/EsClientIT.java#L396


      
              client.indices().refresh(rr -> rr.index("rangequery"));
              SearchResponse<ObjectNode> response = client.search(sr -> sr.index("rangequery")
                              .query(q -> q.range(rq -> rq.field("foo").from("0").to("1")))
                      , ObjectNode.class);
              for (Hit<ObjectNode> hit : response.hits().hits()) {
                  logger.info("hit _id = {}, _source = {}", hit.id(), hit.source());
              }
          }
          
          @Test
          void bulk() throws IOException {
              int size = 1_000;
              try {
                  client.indices().delete(dir -> dir.index("bulk"));
              } catch (ElasticsearchException ignored) { }
          
              BinaryData data = BinaryData.of("{\"foo\":\"bar\"}".getBytes(StandardCharsets.UTF_8), ContentType.APPLICATION_JSON);
              BulkResponse response = client.bulk(br -> {
                  br.index("bulk");
                  for (int i = 0; i < size; i++) {
                      br.operations(o -> o.index(ir -> ir.document(data)));

HTH

system · September 9, 2023, 9:21am

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

Topic		Replies	Views
Using Java High Level Rest client does not auto-retry Bulk requests Elasticsearch	3	3251	March 30, 2018
ElasticsearchClient Java Circuit Breaker errors and retries Elasticsearch language-clients , runtime-fields	1	301	December 20, 2023
Bulk request how to? Elasticsearch	3	1403	June 15, 2022
Sending BulkRequest in Java API Client Elasticsearch version 7.16.3 Elasticsearch language-clients	3	822	March 22, 2022
New Java API client BulkRequest lacks documentation/features Elasticsearch	3	288	June 15, 2022

Handle retries for bulk api

Related topics