diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/TransportResumeFollowAction.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/TransportResumeFollowAction.java
index 36b56fb3d5e..01d76a4ea26 100644
--- a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/TransportResumeFollowAction.java
+++ b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/TransportResumeFollowAction.java
@@ -54,10 +54,10 @@ public class TransportResumeFollowAction extends HandledTransportAction<ResumeFo
 
     static final ByteSizeValue DEFAULT_MAX_BATCH_SIZE = new ByteSizeValue(Long.MAX_VALUE, ByteSizeUnit.BYTES);
     private static final TimeValue DEFAULT_MAX_RETRY_DELAY = new TimeValue(500);
-    private static final int DEFAULT_MAX_CONCURRENT_WRITE_BATCHES = 1;
+    private static final int DEFAULT_MAX_CONCURRENT_WRITE_BATCHES = 9;
     private static final int DEFAULT_MAX_WRITE_BUFFER_SIZE = 10240;
-    private static final int DEFAULT_MAX_BATCH_OPERATION_COUNT = 1024;
-    private static final int DEFAULT_MAX_CONCURRENT_READ_BATCHES = 1;
+    private static final int DEFAULT_MAX_BATCH_OPERATION_COUNT = 5120;
+    private static final int DEFAULT_MAX_CONCURRENT_READ_BATCHES = 12;
     static final TimeValue DEFAULT_POLL_TIMEOUT = TimeValue.timeValueMinutes(1);
 
     private final Client client;