2016-08-08 2 views

答えて

0

リンクの下に読む
client.prepareIndex("index", "doc", "doc1") 
       .setSource("doc") 
       .setConsistencyLevel(WriteConsistencyLevel.QUORUM) 
       .execute() 
       .actionGet() 

+0

**ありがとうございました** elasticsearch 1.5.xでコードがうまく動作するようです。 。 '設定の設定= Settings.settingsBuilder()( "cluster.name"、 "my_clustername")を置く(入れる」:。私は以下のように私のコードので、私のelasticsearchバージョン2.3.2を教えてくれ忘れている index.number_of_replicas "、0).put(" index.number_of_shards "、30).build(); クライアントクライアント= TransportClient.builder()。設定(設定).build()addTransportAddress(新しいInetSocketTransportAddress(InetAddress.getByName( "192.168.3.5")、9300)); ' –

+0

コードは問題ありません。しかし、私のコードはES 2.3.2でうまくいきます。私は試して何も間違っているようです。 – alpert

0

https://www.elastic.co/guide/en/elasticsearch/reference/master/breaking_50_java_api_changes.html#_writeconsistencylevel_removed_on_write_requests

https://www.elastic.co/guide/en/elasticsearch/reference/master/docs-index_.html#index-wait-for-active-shards

私はあなたが、合計で最大の数値を取ることができsetWaitForActiveShardsを、使用することができると思いますシャードコピーの数、またはすべてのシャードコピーのActiveShardCount.ALLです。

関連する問題