diff --git a/es/doc_operation.go b/es/doc_operation.go index 0105fb6d10db6be65a034ca41e146412b75735d1..861bdba5499229e68042acb8f6a31bc3f80dd0fa 100644 --- a/es/doc_operation.go +++ b/es/doc_operation.go @@ -168,7 +168,7 @@ func (c *Client) DeleteByQuery(ctx context.Context, indexName, id, routing strin func (c *Client) BulkDelete(indexName, id, routing string) { bulkDeleteRequest := elastic.NewBulkDeleteRequest().Index(indexName).Id(id) if len(routing) > 0 { - bulkDeleteRequest.Id(routing) + bulkDeleteRequest.Routing(routing) } c.BulkProcessor.Add(bulkDeleteRequest) } @@ -176,7 +176,7 @@ func (c *Client) BulkDelete(indexName, id, routing string) { func (c *Client) BulkDeleteWithVersion(indexName, id, routing string, version int64) { bulkDeleteRequest := elastic.NewBulkDeleteRequest().Index(indexName).Id(id).VersionType(DefaultVersionType).Version(version) if len(routing) > 0 { - bulkDeleteRequest.Id(routing) + bulkDeleteRequest.Routing(routing) } c.BulkProcessor.Add(bulkDeleteRequest) }