diff --git a/es/doc_operation.go b/es/doc_operation.go
index 637558956c3014ad7585d90ad863429bb6698e58..77c36abe18d3289f705c57ade52b1cbcaa24687d 100644
--- a/es/doc_operation.go
+++ b/es/doc_operation.go
@@ -71,7 +71,7 @@ func (c *Client) BulkCreate(indexName, id, routing string, doc interface{}) {
 func (c *Client) BulkCreateDocs(ctx context.Context, indexName string, docs []*BulkCreateDoc) (*elastic.BulkResponse, error) {
 	bulkService := c.Client.Bulk().ErrorTrace(true)
 	for _, doc := range docs {
-		bulkCreateRequest := elastic.NewBulkCreateRequest().Index(indexName)
+		bulkCreateRequest := elastic.NewBulkCreateRequest().Index(indexName).Doc(doc.Doc)
 		if len(doc.ID) > 0 {
 			bulkCreateRequest.Id(doc.ID)
 		}