wuYin opened a new pull request #460: URL: https://github.com/apache/pulsar-client-go/pull/460
Fixes #458 ### Motivation For current producer, send timeout checking triggered by interval batch flush If connection closed, the producer eventloop will blocked to reconnect to broker, lead to batch flush and send timeout checking take no effective, java-client timer did effective in this situation ### Modifications Asynchronized send timeout by running in independent goroutine until producer closed, and without a pending queue lock ### Verifying this change - [ ] Make sure that the change passes the CI checks. ### Others Without pending queue lock, the send timeout checking gets more complicated, I don't know if it's worth it for performance. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
