diff --git a/logstash-core/src/test/java/org/logstash/ackedqueue/QueueTest.java b/logstash-core/src/test/java/org/logstash/ackedqueue/QueueTest.java
index 4fb0d9b85..bb54db094 100644
--- a/logstash-core/src/test/java/org/logstash/ackedqueue/QueueTest.java
+++ b/logstash-core/src/test/java/org/logstash/ackedqueue/QueueTest.java
@@ -456,7 +456,7 @@ public class QueueTest {
 
         assertThat(q.isFull(), is(true));
 
-        Batch b = q.readBatch(9); // read 1 page (10 events)
+        Batch b = q.readBatch(10); // read 1 page (10 events)
         b.close();  // purge 1 page
 
         // spin wait until data is written and write blocks