Hi, I need to transform below code to elastic 8.1.0
private BulkRequest createBulkRequest(List<ElasticSearchMessage> elasticSearchMessages, String indexName) {
BulkRequest bulkRequest = new BulkRequest(indexName);
for (ElasticSearchMessage elasticSearchMessage : elasticSearchMessages) {
final IndexRequest indexRequest = buildIndex(elasticSearchMessage);
bulkRequest.add(indexRequest);
}
return bulkRequest;
}
Since there are no enough docs for Java, it need some support.
I have created IndexRequest
but adding into BulkRequest
is problem. Bulk request isto create index in elastic
BulkRequest bulkRequest = new BulkRequest.Builder()
.build();