From 9474043c299a373e414a65290fdaeeb77e1ef631 Mon Sep 17 00:00:00 2001 From: Ning Yu Date: Mon, 13 Jan 2025 17:46:34 +0800 Subject: [PATCH] fix(tools/perf): fix option name "--max-consume-record-rate" Signed-off-by: Ning Yu --- .../java/org/apache/kafka/tools/automq/perf/PerfConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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")