Укажите конвейер приема Elasticsearch в данных Spring Elasticsearch ⇐ JAVA

[Anonymous]

Я использую клиент Java API Elasticsearch 8.x для индексации документов в Elasticsearch. При индексировании я указываю конвейер приема, который будет выполняться во время приема данных.

Код: Выделить всё

public Mono addContent(RequestDoc requestDoc) {
IndexRequest indexRequest = IndexRequest.of(request -> request
.index("test-index")
.document(requestDoc)
.pipeline("test-ingest-pipeline"));
return reactiveElasticsearchClient.index(indexRequest)
.onErrorResume(IOException.class,
e -> Mono.error(new ElasticsearchPublishException(ES_INDEX_INTERNAL_SERVER_ERROR, e)));
}

Я хочу перенести эту реализацию в Spring data elasticsearch. Можно ли настроить конвейеры приема для индексации документов в Spring data elasticsearch?

Подробнее здесь: https://stackoverflow.com/questions/786 ... sticsearch