diff --git a/pulsar-client-cpp/lib/ProducerConfigurationImpl.h b/pulsar-client-cpp/lib/ProducerConfigurationImpl.h index 7c0b76dfb1dd3..0d2448d22a28a 100644 --- a/pulsar-client-cpp/lib/ProducerConfigurationImpl.h +++ b/pulsar-client-cpp/lib/ProducerConfigurationImpl.h @@ -36,7 +36,7 @@ struct ProducerConfigurationImpl { ProducerConfigurationImpl() : sendTimeoutMs(30000), compressionType(CompressionNone), - maxPendingMessages(1000), + maxPendingMessages(30000), routingMode(ProducerConfiguration::UseSinglePartition), blockIfQueueFull(true), batchingEnabled(false), diff --git a/pulsar-client/src/main/java/com/yahoo/pulsar/client/api/ProducerConfiguration.java b/pulsar-client/src/main/java/com/yahoo/pulsar/client/api/ProducerConfiguration.java index ab905ac1dfc7c..20bf0c3ed6a8b 100644 --- a/pulsar-client/src/main/java/com/yahoo/pulsar/client/api/ProducerConfiguration.java +++ b/pulsar-client/src/main/java/com/yahoo/pulsar/client/api/ProducerConfiguration.java @@ -36,7 +36,7 @@ public class ProducerConfiguration implements Serializable { */ private static final long serialVersionUID = 1L; private long sendTimeoutMs = 30000; - private int maxPendingMessages = 1000; + private int maxPendingMessages = 30000; private boolean blockIfQueueFull = true; private MessageRoutingMode messageRouteMode = MessageRoutingMode.SinglePartition; private MessageRouter customMessageRouter = null;