XLPE opened a new issue, #1032: URL: https://github.com/apache/pulsar-client-go/issues/1032
Pulsar clients periodically call the internalCreatePartitionsProducers method, which we found to be prone to timeouts, triggering the checkServerError method to close the connection and trigger producer reconnection. Since the Pulsar broker is not able to detect the disconnection of the client, the client frequently receives an error message stating that "xxx is already connected to the topic" upon reconnection attempts. This situation can last for several minutes, until the server closes the connection due to keepalive timeout, after which the client can reconnect. #### Expected behavior The invocation of internalCreatePartitionsProducers should not affect the connection of producers. #### Actual behavior The invocation of internalCreatePartitionsProducers causes all connections to be disconnected, resulting in producers being unable to connect to the broker for a long time. -- 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]
