diff --git a/src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java b/src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java index d213bea08..d49b1ad3f 100644 --- a/src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java +++ b/src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java @@ -1182,7 +1182,7 @@ public class SearchEngineClient implements Client { } } - public void addAll(final String index, final List> docList, + public String[] addAll(final String index, final List> docList, final BiConsumer, IndexRequestBuilder> options) { final FessConfig fessConfig = ComponentUtil.getFessConfig(); final BulkRequestBuilder bulkRequestBuilder = client.prepareBulk(); @@ -1210,6 +1210,8 @@ public class SearchEngineClient implements Client { } throw new SearchEngineClientException(response.buildFailureMessage()); } + + return Arrays.stream(response.getItems()).map(res -> res.getId()).toArray(n -> new String[n]); } public static class SearchConditionBuilder {