private void handleElasticsearchException(final Exception e) {
        final String errorDetailMsg = e.getMessage() != null
                ? e.getMessage().substring(0, Math.min(ES_MAX_EXCEPTION_CHARS, e.getMessage().length()))
                : "";

        fatalError("Indexing failed to complete after " + currentRetry + " retries: " + errorDetailMsg, e);
    }
A general Elasticsearch indexing error occurred. Terminate processing and create an `Error` stream.
stroom-search/stroom-search-elastic/src/main/java/stroom/search/elastic/indexing/ElasticIndexingFilter.java