diff --git a/esrally/driver/runner.py b/esrally/driver/runner.py
index 88063e0b0..c3de869a5 100644
--- a/esrally/driver/runner.py
+++ b/esrally/driver/runner.py
@@ -445,6 +445,9 @@ def detailed_stats(self, params, bulk_size, response):
         if bulk_error_count > 0:
             stats["error-type"] = "bulk"
             stats["error-description"] = self.error_description(error_details)
+        if "ingest_took" in response:
+            stats["ingest_took"] = response["ingest_took"]
+
         return stats
 
     def simple_stats(self, bulk_size, response):
@@ -462,6 +465,8 @@ def simple_stats(self, bulk_size, response):
             "success-count": bulk_size - bulk_error_count,
             "error-count": bulk_error_count
         }
+        if "ingest_took" in response:
+            stats["ingest_took"] = response["ingest_took"]
         if bulk_error_count > 0:
             stats["error-type"] = "bulk"
             stats["error-description"] = self.error_description(error_details)
diff --git a/tests/driver/runner_test.py b/tests/driver/runner_test.py
index 044bff509..ddcd0d462 100644
--- a/tests/driver/runner_test.py
+++ b/tests/driver/runner_test.py
@@ -376,6 +376,7 @@ def test_bulk_index_error_no_shards(self, es):
     def test_mixed_bulk_with_simple_stats(self, es):
         es.bulk.return_value = {
             "took": 30,
+            "ingest_took": 20,
             "errors": True,
             "items": [
                 {
@@ -469,6 +470,7 @@ def test_mixed_bulk_with_simple_stats(self, es):
 
         self.assertEqual("test", result["index"])
         self.assertEqual(30, result["took"])
+        self.assertEqual(20, result["ingest_took"])
         self.assertEqual(4, result["weight"])
         self.assertEqual(4, result["bulk-size"])
         self.assertEqual("docs", result["unit"])
@@ -478,10 +480,16 @@ def test_mixed_bulk_with_simple_stats(self, es):
 
         es.bulk.assert_called_with(body=bulk_params["body"], params={})
 
+        es.bulk.return_value.pop("ingest_took")
+        result = bulk(es, bulk_params)
+        self.assertNotIn("ingest_took", result)
+
+
     @mock.patch("elasticsearch.Elasticsearch")
     def test_mixed_bulk_with_detailed_stats(self, es):
         es.bulk.return_value = {
             "took": 30,
+            "ingest_took": 20,
             "errors": True,
             "items": [
                 {
@@ -613,6 +621,7 @@ def test_mixed_bulk_with_detailed_stats(self, es):
 
         self.assertEqual("test", result["index"])
         self.assertEqual(30, result["took"])
+        self.assertEqual(20, result["ingest_took"])
         self.assertEqual(6, result["weight"])
         self.assertEqual(6, result["bulk-size"])
         self.assertEqual("docs", result["unit"])
@@ -665,6 +674,10 @@ def test_mixed_bulk_with_detailed_stats(self, es):
 
         es.bulk.assert_called_with(body=bulk_params["body"], params={})
 
+        es.bulk.return_value.pop("ingest_took")
+        result = bulk(es, bulk_params)
+        self.assertNotIn("ingest_took", result)
+
 
 class ForceMergeRunnerTests(TestCase):
     @mock.patch("elasticsearch.Elasticsearch")