michaeljmarshall opened a new pull request, #16616: URL: https://github.com/apache/pulsar/pull/16616
Related: https://github.com/apache/pulsar/pull/13161 and https://github.com/apache/pulsar/pull/12948 ### Motivation The current Java Client consumer code does not clean up a pending consumer on the server when the client's timeout expires. This creates problems when the client tries to recreate the consumer with a `Subscribe` command. In this case, we see warnings like the following: >2022-07-13T23:51:53,323+0000 [pulsar-io-12-6] WARN org.apache.pulsar.broker.service.ServerCnx - [/10.249.212.73:41536][persistent://public/default/test][test] Consumer with id is already present on the connection, consumerId=66 ### Modifications * Send `CloseConsumer` command when the `Subscribe` command times out from the client perspective. ### Verifying this change This change includes new tests. ### Does this pull request potentially affect one of the following parts: This change introduces new recommendation for the Pulsar Protocol, but it does not make any breaking changes. ### Documentation - [x] `doc` -- 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]
