Fix IndexOutOfBoundsException when --subscriptions size is less than …

…--num-subscriptions in consumption (apache#11797)
lhotari · Sep 6, 2021 · 652fa23 · 652fa23
1 parent d4055b5
commit 652fa23
Showing 1 changed file with 2 additions and 4 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
@@ -223,9 +223,7 @@ public static void main(String[] args) throws Exception {
             PerfClientUtils.exit(-1);
         }
 
-        if (arguments.subscriptionType != SubscriptionType.Exclusive &&
-                arguments.subscriptions != null &&
-                arguments.subscriptions.size() != arguments.numConsumers) {
+        if (arguments.subscriptions != null && arguments.subscriptions.size() != arguments.numSubscriptions) {
             // keep compatibility with the previous version
             if (arguments.subscriptions.size() == 1) {
                 List<String> defaultSubscriptions = Lists.newArrayList();
@@ -234,7 +232,7 @@ public static void main(String[] args) throws Exception {
                 }
                 arguments.subscriptions = defaultSubscriptions;
             } else {
-                System.out.println("The size of subscriptions list should be equal to --num-consumers when subscriptionType isn't Exclusive");
+                System.out.println("The size of subscriptions list should be equal to --num-subscriptions");
                 jc.usage();
                 PerfClientUtils.exit(-1);
             }