diff --git a/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java b/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
index a9833df3..b5641df9 100644
--- a/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
+++ b/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
@@ -65,6 +65,7 @@ public static void main(String[] args) throws Exception {
             Duration.ofMillis(Integer.parseInt(env.getTestProperty(TestProps.CI_BW_SLEEP_MS)));
         while (true) {
           try (BatchScanner bs = client.createBatchScanner(env.getAccumuloTableName(), auths)) {
+            bs.setConsistencyLevel(cl);
             Set<Text> batch =
                 getBatch(scanner, env.getRowMin(), env.getRowMax(), scanBatchSize, env.getRandom());
             List<Range> ranges = batch.stream().map(Range::new).collect(Collectors.toList());