merlimat opened a new issue, #235: URL: https://github.com/apache/pulsar-client-cpp/issues/235
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version 3.1.1 ### Minimal reproduce step After unload or TCP connection reset, some consumers are staying in a non-connected state. ### What did you expect to see? Consumer reconnecting ### What did you see instead? There are 2 attempts to reconnect. From the broker side, the 1st is successful, although the client immediately tries again. The 2nd attempt fails, because this is an exclusive subscription. After that, there are no more attempts from the consumer. ``` 2023-03-27T02:21:15,665+0000 [pulsar-io-4-11] INFO org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer - Removing consumer Consumer{subscription=PersistentSubscription{topic=persistent://public/default/my-topic, name=sub}, consumerId=0, consumerName=consumer-b4p4c, address=/127.0.0.6:45003} 2023-03-27T02:21:16,123+0000 [pulsar-io-4-17] INFO org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.6:55081] Subscribing on topic persistent://public/default/my-topic / sub 2023-03-27T02:21:16,123+0000 [pulsar-io-4-17] INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [public/default/persistent/my-topic-sub] Rewind from 3024288:69842 to 3024288:69784 2023-03-27T02:21:16,123+0000 [pulsar-io-4-17] INFO org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/default/my-topic][sub] Created new subscription for 0 2023-03-27T02:21:16,123+0000 [pulsar-io-4-17] INFO org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.6:55081] Created subscription on topic persistent://public/default/my-topic / sub 2023-03-27T02:21:16,281+0000 [pulsar-io-4-17] INFO org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.6:55081] Subscribing on topic persistent://public/default/my-topic / sub 2023-03-27T02:21:16,281+0000 [pulsar-io-4-17] INFO org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.6:55081] Consumer with the same id is already created: consumerId=0, consumer=Consumer{subscription=PersistentSubscription{topic=persistent://public/default/my-topic, name=sub}, consumerId=0, consumerName=consumer-b4p4c, address=/127.0.0.6:55081} ``` ### Anything else? _No response_ ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
