2017-12-06 12 views
0

以前私のアプリでTransportClientを使用していました。 最近、AWS向けにElastic Searchサービスを管理しています。 AWSが管理するESクラスタはTransportClientをサポートしないことを学びました。RestHighLevelClient with BulkProcessorエラスティック検索の問題

したがって、BulkProcessortを使用しているコードを移行してESに文書を挿入します。 ESドキュメンテーションの一部としてコードをリファクタリングするときに、この行を追加しました。

BulkProcessor bulkProcessor = BulkProcessor.builder(client::bulkAsync, listener).build(); 

クライアントではエラーが発生しました:: bulkAsyncクライアントは機能的なインターフェイスではありません。

私が間違っていることを理解するのに役立つ必要があります。参考のため

文書リンク、

https://www.elastic.co/guide/en/elasticsearch/client/java-rest/master/java-rest-high-document-bulk.html#java-rest-high-document-bulk-processor

答えて

0

クライアントオブジェクトの種類は何ですか? RestHighLevelClientインスタンスである必要があります。 依存私のMVN 組織 https://github.com/dadoonet/legacy-search/blob/02-bulk/src/main/java/fr/pilato/demo/legacysearch/dao/ElasticsearchDao.java

+0

はいRestHighLevelClientを使用しています、と私は上記のDAOをコピーして、まだ私はIDEでesClient :: bulkAsyncとエラーが表示され、ここにある:ここで

は、作業コードです elasticsearch休止・高レベルのクライアント 6.0.1 camelBeginner

+0

.elasticsearch.clientそれは私のミスですが、私はanotを持っていました私のPOMにJESTの依存関係があり、エラーが発生しました。機能的なインターフェースではありません。私はJESTを削除し、エラーもなくなっています。 – camelBeginner