[pulsar] 02/06: [pulsar-perf] Make it possible to disable poolMessages (#12090)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 1b4b71b07564b2dd68f83e675b7c5fdd5ba4dbbe
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Mon Sep 20 19:52:45 2021 +0300

    [pulsar-perf] Make it possible to disable poolMessages (#12090)
    
    - JCommander requires passing arity = 1 to boolean parameters that
      have a default value of true.
    
    (cherry picked from commit 898582b2a2a5f64f911c569befef92b5d56c7ed8)
---
 .../main/java/org/apache/pulsar/testclient/PerformanceConsumer.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
index 4045a27..59ffac3 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
@@ -172,11 +172,11 @@ public class PerformanceConsumer {
         @Parameter(names = {"-ioThreads", "--num-io-threads"}, description = "Set the number of threads to be " +
                 "used for handling connections to brokers, default is 1 thread")
         public int ioThreads = 1;
-    
+
         @Parameter(names = {"--batch-index-ack" }, description = "Enable or disable the batch index acknowledgment")
         public boolean batchIndexAck = false;
 
-        @Parameter(names = { "-pm", "--pool-messages" }, description = "Use the pooled message")
+        @Parameter(names = { "-pm", "--pool-messages" }, description = "Use the pooled message", arity = 1)
         private boolean poolMessages = true;
 
         @Parameter(names = {"-bw", "--busy-wait"}, description = "Enable Busy-Wait on the Pulsar client")