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/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new d05f94d Performance producer was not using the max producer queue size argument (#1187) d05f94d is described below commit d05f94d592b7aadf6a884a3eec154b705deba9b7 Author: Matteo Merli <mme...@apache.org> AuthorDate: Tue Feb 6 10:58:58 2018 -0800 Performance producer was not using the max producer queue size argument (#1187) --- .../src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java | 1 + 1 file changed, 1 insertion(+) 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 c9ac1e8..78a53b8 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 @@ -269,6 +269,7 @@ public class PerformanceProducer { ProducerConfiguration producerConf = new ProducerConfiguration(); producerConf.setSendTimeout(0, TimeUnit.SECONDS); producerConf.setCompressionType(arguments.compression); + producerConf.setMaxPendingMessages(arguments.maxOutstanding); // enable round robin message routing if it is a partitioned topic producerConf.setMessageRoutingMode(MessageRoutingMode.RoundRobinPartition); if (arguments.batchTime > 0) { -- To stop receiving notification emails like this one, please contact mme...@apache.org.