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

github-actions[bot] · Anaethelion · web-flow · commit 2a10249ea70a · 2022-02-10T13:59:30.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
@@ -430,7 +430,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
`@@ -430,7 +430,7 @@ func (w *worker) writeMeta(item BulkIndexerItem) error {`
`430`	`430`	`if item.DocumentID != "" {`
`431`	`431`	`w.buf.WriteRune(',')`
`432`	`432`	`}`
`433`		- w.buf.WriteString(`"_routing":`)
	`433`	+ w.buf.WriteString(`"routing":`)
`434`	`434`	`w.aux = strconv.AppendQuote(w.aux, item.Routing)`
`435`	`435`	`w.buf.Write(w.aux)`
`436`	`436`	`w.aux = w.aux[:0]`