diff --git a/tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java b/tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java
index a14df3ea2f..b72e2ccf23 100644
--- a/tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java
+++ b/tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java
@@ -63,6 +63,7 @@ public ConsumerService(String bootstrapServer) {
         Properties properties = new Properties();
         properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServer);
         properties.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, (int) TimeUnit.SECONDS.toMillis(300));
+        properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
         this.admin = Admin.create(properties);
         this.groupSuffix = new SimpleDateFormat("HHmmss").format(System.currentTimeMillis());
     }