feat(shell): new consumer in pref command should start consuming from…

… the beginning

Signed-off-by: SSpirits <[email protected]>

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());
     }