}
                final BulkResponse response = bulkRequest.execute().actionGet(30_000L);
                if (response.hasFailures()) {
                    logger.warn("Failed to write log notifications: {}", response.buildFailureMessage());
                }
            }
        } catch (final Exception e) {

                        return StringUtil.EMPTY;
                    });
            final BulkResponse response = builder.execute().actionGet(fessConfig.getIndexBulkTimeout());
            if (response.hasFailures()) {
                if (createOnly) {
                    final long realFailures = Arrays.stream(response.getItems())