everesio opened a new issue #293: URL: https://github.com/apache/pulsar-client-go/issues/293
The context.Context parameter of the producer Send and SendAsync methods is not used correctly. When the pulsar sever is down: a. Send method hangs forever waiting on wg.Wait() in the partitionProducer::Send b. SendAsync callback is never invoked. In both cases context timeout was ignored. Additionally blocked Sync can prevent application shutdown e.g. result of the context cancellation due to SIGINT. #### Expected behavior Error after context timeout / context cancellation. #### Actual behavior Method blocked forever, callback is not invoked with error #### Steps to reproduce 1. Service starts up and produces message 2. Pulsar server shutdown 3A. Service send a message with context.WithTimeout 3B. SIGINT cancels the from context.WithCancel #### System configuration 2.5.2 ---------------------------------------------------------------- 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]
