import static org.elasticsearch.common.xcontent.XContentFactory.*; 
 
        BulkRequestBuilder bulkRequest = client.prepareBulk(); 
 
        bulkRequest.add(client.prepareIndex("twitter", "tweet", "1") 
                .setSource(jsonBuilder() 
                            .startObject() 
                                .field("user", "kimchy") 
                                .field("postDate", new Date()) 
                                .field("message", "trying out Elastic Search") 
                            .endObject() 
                          ) 
                ); 
 
        bulkRequest.add(client.prepareIndex("twitter", "tweet", "2") 
                .setSource(jsonBuilder() 
                            .startObject() 
                                .field("user", "kimchy") 
                                .field("postDate", new Date()) 
                                .field("message", "another post") 
                            .endObject() 
                          ) 
                ); 
 
        BulkResponse bulkResponse = bulkRequest.execute().actionGet(); 
        if (bulkResponse.hasFailures()) { 
            //处理错误 
        }