diff --git a/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ConsumerPerformance.java b/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ConsumerPerformance.java index 7f0d6405..04899d82 100644 --- a/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ConsumerPerformance.java +++ b/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ConsumerPerformance.java @@ -104,7 +104,9 @@ public static void main(String[] args) throws Exception { /** Get the command-line argument parser. */ private static ArgumentParser argParser() { - ArgumentParser parser = ArgumentParsers.newArgumentParser("consumer-performance").defaultHelp(true) + ArgumentParser parser = ArgumentParsers.newFor("consumer-performance") + .addHelp(true) + .build() .description("This tool is used to verify the consumer performance."); parser.addArgument("--topic") diff --git a/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java b/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java index 0dc9040b..fa557faf 100644 --- a/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java +++ b/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java @@ -121,7 +121,9 @@ private static byte[] randomBytesOfLen(Random random, int len) { /** Get the command-line argument parser. */ private static ArgumentParser argParser() { - ArgumentParser parser = ArgumentParsers.newArgumentParser("end-to-end-latency").defaultHelp(true) + ArgumentParser parser = ArgumentParsers.newFor("end-to-end-latency") + .addHelp(true) + .build() .description("This tool is used to verify end to end latency."); parser.addArgument("--bootstrap-servers") diff --git a/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ProducerPerformance.java b/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ProducerPerformance.java index fa6fb6fa..8aea38c9 100644 --- a/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ProducerPerformance.java +++ b/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ProducerPerformance.java @@ -108,8 +108,9 @@ public static void main(String[] args) throws Exception { /** Get the command-line argument parser. */ private static ArgumentParser argParser() { ArgumentParser parser = ArgumentParsers - .newArgumentParser("producer-performance") - .defaultHelp(true) + .newFor("producer-performance") + .addHelp(true) + .build() .description("This tool is used to verify the producer performance."); parser.addArgument("--topic")