In addition to the 409 errros, also ignore valid 201 created document…

…s within a "errors=true" elastic bulk response Signed-off-by: Daniel Steininger <[email protected]>
fluent · Jun 19, 2024 · 9311604 · 9311604
1 parent 2bef958
commit 9311604
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/plugins/out_es/es.c b/plugins/out_es/es.c
@@ -777,8 +777,11 @@ static int elasticsearch_error_check(struct flb_elasticsearch *ctx,
                             check = FLB_TRUE;
                             goto done;
                         }
-                        /* Check for errors other than version conflict (document already exists) */
-                        if (item_val.via.i64 != 409) {
+                        /* 
+                         * Check for errors other than version conflict (document already exists)
+                         * and ignore the created documents.
+                         */
+                        if (item_val.via.i64 != 409 && item_val.via.i64 != 201) {
                             check = FLB_TRUE;
                             goto done;
                         }