You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by yu...@apache.org on 2018/02/08 10:08:38 UTC
[incubator-pulsar] branch master updated: Perf producer was
overriding the producer max queue size (#1202)
This is an automated email from the ASF dual-hosted git repository.
yushiga pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b538165 Perf producer was overriding the producer max queue size (#1202)
b538165 is described below
commit b53816507997074be56744345bdd82f37b55c5b2
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Thu Feb 8 02:08:35 2018 -0800
Perf producer was overriding the producer max queue size (#1202)
---
.../src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java | 1 -
1 file changed, 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
index 78a53b8..4ab25d0 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
@@ -275,7 +275,6 @@ public class PerformanceProducer {
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
--
To stop receiving notification emails like this one, please contact
yushiga@apache.org.