Fix BulkIndexerItem Routing field serialization (#426) (#428)

github-actions[bot] · Anaethelion · web-flow · commit 7afcd344ee7b · 2022-02-10T13:59:37.000+01:00
Co-authored-by: Laurent Saint-Félix &lt;laurent.saintfelix@elastic.co&gt;
diff --git a/esutil/bulk_indexer.go b/esutil/bulk_indexer.go
@@ -428,7 +428,7 @@ func (w *worker) writeMeta(item BulkIndexerItem) error {
 		if item.DocumentID != "" {
 			w.buf.WriteRune(',')
 		}
-		w.buf.WriteString(`"_routing":`)
+		w.buf.WriteString(`"routing":`)
 		w.aux = strconv.AppendQuote(w.aux, item.Routing)
 		w.buf.Write(w.aux)
 		w.aux = w.aux[:0]
diff --git a/esutil/bulk_indexer_integration_test.go b/esutil/bulk_indexer_integration_test.go
@@ -212,6 +212,7 @@ func TestBulkIndexerIntegration(t *testing.T) {
 							Body:        strings.NewReader(body),
 							Version:     &version,
 							VersionType: "external",
+							Routing:     `"{required": true}`,
 							OnSuccess: func(ctx context.Context, item esutil.BulkIndexerItem, item2 esutil.BulkIndexerResponseItem) {
 								if version != item2.Version &&
 									version != *item.Version &&

Original file line number	Diff line number	Diff line change
`@@ -428,7 +428,7 @@ func (w *worker) writeMeta(item BulkIndexerItem) error {`
`428`	`428`	`if item.DocumentID != "" {`
`429`	`429`	`w.buf.WriteRune(',')`
`430`	`430`	`}`
`431`		- w.buf.WriteString(`"_routing":`)
	`431`	+ w.buf.WriteString(`"routing":`)
`432`	`432`	`w.aux = strconv.AppendQuote(w.aux, item.Routing)`
`433`	`433`	`w.buf.Write(w.aux)`
`434`	`434`	`w.aux = w.aux[:0]`