tisonkun commented on issue #1067: URL: https://github.com/apache/pulsar-client-go/issues/1067#issuecomment-1778767653
> This is because we use publishSemaphore instead of capacity of dataChan to limit pending messages. The actual limit is 2X of MaxPendingMessages. What does it mean? Both `publishSemaphore` and `dataChan` has n=MaxPendingMessages permits to use. ```java dataChan: make(chan *sendRequest, maxPendingMessages), publishSemaphore: internal.NewSemaphore(int32(maxPendingMessages)), ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
