fix: fix 1067

apache · Jul 21, 2023 · 152520d · 152520d
1 parent 9867c29
commit 152520d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -145,7 +145,7 @@ func newPartitionProducer(client *client, topic string, options *ProducerOptions
 		log:              logger,
 		options:          options,
 		producerID:       client.rpcClient.NewProducerID(),
-		dataChan:         make(chan *sendRequest, maxPendingMessages),
+		dataChan:         make(chan *sendRequest, 10),
 		cmdChan:          make(chan interface{}, 10),
 		connectClosedCh:  make(chan connectionClosed, 10),
 		batchFlushTicker: time.NewTicker(batchingMaxPublishDelay),