diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java index fd91101ee4986..53a6f26170c78 100644 --- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java +++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java @@ -172,7 +172,7 @@ public interface ProducerBuilder extends Cloneable { * the client application. Until, the producer gets a successful acknowledgment back from the broker, * it will keep in memory (direct memory pool) all the messages in the pending queue. * - *

Default is 1000. + *

Default is 0, disable the pending messages check. * * @param maxPendingMessages * the max size of the pending messages queue for the producer @@ -188,7 +188,7 @@ public interface ProducerBuilder extends Cloneable { * The purpose of this setting is to have an upper-limit on the number * of pending messages when publishing on a partitioned topic. * - *

Default is 50000. + *

Default is 0, disable the pending messages across partitions check. * *

If publishing at high rate over a topic with many partitions (especially when publishing messages without a * partitioning key), it might be beneficial to increase this parameter to allow for more pipelining within the @@ -198,6 +198,7 @@ public interface ProducerBuilder extends Cloneable { * max pending messages across all the partitions * @return the producer builder instance */ + @Deprecated ProducerBuilder maxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions); /** diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java index 497b82a78c7f8..90a2fc8666a1e 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java @@ -145,6 +145,7 @@ public ProducerBuilder maxPendingMessages(int maxPendingMessages) { return this; } + @Deprecated @Override public ProducerBuilder maxPendingMessagesAcrossPartitions(int maxPendingMessagesAcrossPartitions) { conf.setMaxPendingMessagesAcrossPartitions(maxPendingMessagesAcrossPartitions); diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java index e4f86d383aaca..b2c62ca10b40d 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java @@ -270,9 +270,9 @@ public class ClientConfigurationData implements Serializable, Cloneable { @ApiModelProperty( name = "memoryLimitBytes", - value = "Limit of client memory usage (in byte)." + value = "Limit of client memory usage (in byte). The 64M default can guarantee a high producer throughput." ) - private long memoryLimitBytes = 0; + private long memoryLimitBytes = 64 * 1024 * 1024; @ApiModelProperty( name = "proxyServiceUrl", diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java index 18a70a6e8ccc7..08fc096e66029 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java @@ -53,8 +53,8 @@ public class ProducerConfigurationData implements Serializable, Cloneable { private static final long serialVersionUID = 1L; public static final int DEFAULT_BATCHING_MAX_MESSAGES = 1000; - public static final int DEFAULT_MAX_PENDING_MESSAGES = 1000; - public static final int DEFAULT_MAX_PENDING_MESSAGES_ACROSS_PARTITIONS = 50000; + public static final int DEFAULT_MAX_PENDING_MESSAGES = 0; + public static final int DEFAULT_MAX_PENDING_MESSAGES_ACROSS_PARTITIONS = 0; private String topicName = null; private String producerName = null; diff --git a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerBuilderImplTest.java b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerBuilderImplTest.java index 21708c25f7537..9a53bc6146037 100644 --- a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerBuilderImplTest.java +++ b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ProducerBuilderImplTest.java @@ -346,12 +346,12 @@ public void testProducerBuilderImplWhenSendTimeoutPropertyIsNegative() { @Test(expectedExceptions = IllegalArgumentException.class) public void testProducerBuilderImplWhenMaxPendingMessagesAcrossPartitionsPropertyIsInvalid() { - producerBuilderImpl.maxPendingMessagesAcrossPartitions(999); + producerBuilderImpl.maxPendingMessagesAcrossPartitions(-1); } @Test(expectedExceptions = IllegalArgumentException.class, expectedExceptionsMessageRegExp = "maxPendingMessagesAcrossPartitions needs to be >= maxPendingMessages") public void testProducerBuilderImplWhenMaxPendingMessagesAcrossPartitionsPropertyIsInvalidErrorMessages() { - producerBuilderImpl.maxPendingMessagesAcrossPartitions(999); + producerBuilderImpl.maxPendingMessagesAcrossPartitions(-1); } @Test