[pulsar] branch master updated: [pulsar-perf] Change the default for max-connections from 100 to 1 (#15387)

[mmerli]

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

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 74747b1c17c [pulsar-perf] Change the default for max-connections from 
100 to 1 (#15387)
74747b1c17c is described below

commit 74747b1c17c77dcd0a71a767307aaf8726c9d925
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Fri Apr 29 23:13:54 2022 +0300

    [pulsar-perf] Change the default for max-connections from 100 to 1 (#15387)
---
 .../src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java | 2 +-
 .../src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java | 2 +-
 .../src/main/java/org/apache/pulsar/testclient/PerformanceReader.java   | 2 +-
 .../main/java/org/apache/pulsar/testclient/PerformanceTransaction.java  | 2 +-
 4 files changed, 4 insertions(+), 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
index bdee5e2df08..0b9b719bfa2 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
@@ -150,7 +150,7 @@ public class PerformanceConsumer {
 
         @Parameter(names = { "-c",
                 "--max-connections" }, description = "Max number of TCP 
connections to a single broker")
-        public int maxConnections = 100;
+        public int maxConnections = 1;
 
         @Parameter(names = { "-i",
                 "--stats-interval-seconds" },
diff --git 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
index f18f4a84e13..ea40aa31ae2 100644
--- 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
+++ 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
@@ -182,7 +182,7 @@ public class PerformanceProducer {
 
         @Parameter(names = { "-c",
                 "--max-connections" }, description = "Max number of TCP 
connections to a single broker")
-        public int maxConnections = 100;
+        public int maxConnections = 1;
 
         @Parameter(names = { "-m",
                 "--num-messages" }, description = "Number of messages to 
publish in total. If <= 0, it will keep "
diff --git 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
index dee3a6c57c1..724cb4378b3 100644
--- 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
+++ 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
@@ -96,7 +96,7 @@ public class PerformanceReader {
 
         @Parameter(names = { "-c",
                 "--max-connections" }, description = "Max number of TCP 
connections to a single broker")
-        public int maxConnections = 100;
+        public int maxConnections = 1;
 
         @Parameter(names = { "-i",
                 "--stats-interval-seconds" },
diff --git 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
index 31e566919ba..52af64d1bea 100644
--- 
a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
+++ 
b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
@@ -142,7 +142,7 @@ public class PerformanceTransaction {
 
         @Parameter(names = {"-c",
                 "--max-connections"}, description = "Max number of TCP 
connections to a single broker")
-        public int maxConnections = 100;
+        public int maxConnections = 1;
 
         @Parameter(names = {"-time",
                 "--test-duration"}, description = "Test duration (in second). 
0 means keeping publishing")