Perf producer was overriding the producer max queue size (apache#1202)

willome · Feb 8, 2018 · b538165 · b538165
1 parent b7e2e7c
commit b538165
Showing 1 changed file with 0 additions and 1 deletion.
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
@@ -275,7 +275,6 @@ public EncryptionKeyInfo getPrivateKey(String keyName, Map<String, String> keyMe
         if (arguments.batchTime > 0) {
             producerConf.setBatchingMaxPublishDelay(arguments.batchTime, TimeUnit.MILLISECONDS);
             producerConf.setBatchingEnabled(true);
-            producerConf.setMaxPendingMessages(arguments.msgRate);
         }
 
         // Block if queue is full else we will start seeing errors in sendAsync