diff --git a/pulsar/consumer_impl.go b/pulsar/consumer_impl.go
index b5de1f925b..ddfff4c0f6 100644
--- a/pulsar/consumer_impl.go
+++ b/pulsar/consumer_impl.go
@@ -91,7 +91,7 @@ func newConsumer(client *client, options ConsumerOptions) (Consumer, error) {
 	}
 
 	if options.ReceiverQueueSize <= 0 {
-		options.ReceiverQueueSize = 1000
+		options.ReceiverQueueSize = defaultReceiverQueueSize
 	}
 
 	if options.Interceptors == nil {
diff --git a/pulsar/reader_impl.go b/pulsar/reader_impl.go
index 8083b06973..17a7084e64 100644
--- a/pulsar/reader_impl.go
+++ b/pulsar/reader_impl.go
@@ -85,7 +85,7 @@ func newReader(client *client, options ReaderOptions) (Reader, error) {
 	subscriptionName += "-" + generateRandomName()
 
 	receiverQueueSize := options.ReceiverQueueSize
-	if receiverQueueSize == 0 {
+	if receiverQueueSize <= 0 {
 		receiverQueueSize = defaultReceiverQueueSize
 	}