Merge branch 'master' into datastreams

* master:
  Feat: assert returned item count from _bulk (logstash-plugins#997)

Author: kares

CHANGELOG.md

@@ -2,6 +2,9 @@
  - Feat: Data stream support [#988](https://github.com/logstash-plugins/logstash-output-elasticsearch/pull/988)
  - Refactor: unified logging + improvements when ES returns invalid bulk response see [#989](https://github.com/logstash-plugins/logstash-output-elasticsearch/issues/989) 
 
+## 10.8.5
+ - Feat: assert returned item count from _bulk [#997](https://github.com/logstash-plugins/logstash-output-elasticsearch/pull/997)
+
 ## 10.8.4
  - Fixed an issue where a retried request would drop "update" parameters [#800](https://github.com/logstash-plugins/logstash-output-elasticsearch/pull/800)
 

lib/logstash/plugin_mixins/elasticsearch/common.rb

@@ -232,8 +232,9 @@ def submit(actions)
 
       responses = bulk_response["items"]
       if responses.size != actions.size # can not map action -> response reliably
+        # an ES bug (on 7.10.2, 7.11.1) where a _bulk request to index X documents would return Y (> X) items
         msg = "Sent #{actions.size} documents but Elasticsearch returned #{responses.size} responses"
-        @logger.debug? && @logger.debug(msg, actions: actions, responses: responses)
+        @logger.warn(msg, actions: actions, responses: responses)
         fail("#{msg} (likely a bug with _bulk endpoint)")
       end