Use maxPendingMessages for sizing producer eventsChan (#285)

apache · Jun 18, 2020 · f6198df · f6198df
1 parent 1e00fb6
commit f6198df
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -92,7 +92,7 @@ func newPartitionProducer(client *client, topic string, options *ProducerOptions
 		topic:            topic,
 		options:          options,
 		producerID:       client.rpcClient.NewProducerID(),
-		eventsChan:       make(chan interface{}, 10),
+		eventsChan:       make(chan interface{}, maxPendingMessages),
 		batchFlushTicker: time.NewTicker(batchingMaxPublishDelay),
 		publishSemaphore: make(internal.Semaphore, maxPendingMessages),
 		pendingQueue:     internal.NewBlockingQueue(maxPendingMessages),