Throw exception if any record fails and Log the response

src/Indexers/BulkIndexer.php

@@ -11,7 +11,10 @@
 class BulkIndexer implements IndexerInterface
 {
     /**
-     * {@inheritdoc}
+     * @param Collection $models
+     *
+     * @return array|void
+     * @throws \Exception
      */
     public function update(Collection $models)
     {
@@ -50,7 +53,20 @@ public function update(Collection $models)
                 ->add('body', $modelData);
         });
 
-        ElasticClient::bulk($bulkPayload->get());
+        $response = ElasticClient::bulk($bulkPayload->get());
+
+        if ($response['errors']) {
+
+            // Response included every record's status which is a lot to dig through when chunking by thousand
+            // Sort through the items to only log the failed items
+            foreach ($response['items'] as $item) {
+                if ($item['index']['error']) {
+                    Log::error($item);
+                }
+            }
+
+            throw new Exception('ElasticSearch responded with an error');
+        }
     }
 
     /**