You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/09/29 10:40:31 UTC

[pulsar] 01/08: [pulsar-client] Make it possible to disable poolMessages (#12108)

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 cd2dd0618b47bec3c34478d634f66e7293d77a32
Author: Ruguo Yu <ji...@163.com>
AuthorDate: Fri Sep 24 18:29:59 2021 +0800

    [pulsar-client] Make it possible to disable poolMessages (#12108)
    
    
    (cherry picked from commit 4aae519c01e48439fc074ef6e8a799272a411344)
---
 .../src/main/java/org/apache/pulsar/client/cli/CmdConsume.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
index b614be0..6264ed6 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
@@ -127,7 +127,7 @@ public class CmdConsume {
     @Parameter(names = { "-st", "--schema-type"}, description = "Set a schema type on the consumer, it can be 'bytes' or 'auto_consume'")
     private String schematype = "bytes";
 
-    @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;
 
     private ClientBuilder clientBuilder;