diff --git a/tools/src/main/java/org/apache/kafka/tools/automq/perf/PerfConfig.java b/tools/src/main/java/org/apache/kafka/tools/automq/perf/PerfConfig.java index 2e81c745aa..da9d282fd9 100644 --- a/tools/src/main/java/org/apache/kafka/tools/automq/perf/PerfConfig.java +++ b/tools/src/main/java/org/apache/kafka/tools/automq/perf/PerfConfig.java @@ -212,7 +212,7 @@ public static ArgumentParser parser() { .dest("sendRateDuringCatchup") .metavar("SEND_RATE_DURING_CATCHUP") .help("The send rate in messages per second during catchup. If not set, the send rate will be used."); - parser.addArgument("-m", "--max-poll-rate") + parser.addArgument("-m", "--max-consume-record-rate") .setDefault(1_000_000_000) .type(between(0, 1_000_000_000)) .dest("maxConsumeRecordRate")