Gleiphir2769 opened a new issue, #1067: URL: https://github.com/apache/pulsar-client-go/issues/1067
Hi community. I noticed that the capacity of dataChan is too big. We make the `dataChan` with capacity `MaxPendingMessages` and the account of pending messages actual in queue may exceed the limit by `MaxPendingMessages` a lot. This is because we use `publishSemaphore` instead of capacity of `dataChan` to limit pending messages. The actual limit is 2X the `MaxPendingMessages`. https://github.com/apache/pulsar-client-go/blob/9867c29ca329302e97ddd9c6a99f66853c7f447f/pulsar/producer_partition.go#L148 -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
