codelipenghui commented on PR #20927:
URL: https://github.com/apache/pulsar/pull/20927#issuecomment-1705935520
> During the process of creating a subscription, when checking if the
transaction pending has been initialized using return store.exists(PREFIX +
path);, a connection failure error occurred while connecting to ZooKeeper.
However, the created subscription continues to exist in the PersistentTopic,
which causes subsequent retries to keep using the same subscription.
@liangyepianzhou In such a scenario, the "subscribe" command should be
deemed unsuccessful. The PendingAck module, being a part of the system, should
focus solely on cleaning up its own state and subsequently notifying the caller
of the failure it encountered. Then the caller("subscribe") should cleanup it's
own state.
--
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]
