[GitHub] [pulsar-client-go] wolfstudy opened a new pull request, #774: Fix sequenceID is not equal to cause the connection to be closed incorrectly

[GitBox <gi...@apache.org>]

wolfstudy opened a new pull request, #774:
URL: https://github.com/apache/pulsar-client-go/pull/774

   ### Motivation
   
   When processing the sendReceipt command, if the sequenceID returned by the broker is greater than the sequenceID in the current pendingQueue, we need to close the current connection to fix the inconsistency between the broker and the client state.
   When the sequenceID returned by the broker is smaller than the sequenceID in the current pendingQueue, we do not need to close the current connection, and expect to increment the value of the returned sequenceID when the broker retries next time.
   
   The current code processing logic is just the opposite, resulting in the failure to recover after the first situation occurs, and a phenomenon similar to the following occurs:
   
   <img width="1506" alt="image" src="https://user-images.githubusercontent.com/20965307/167880602-0251dcd6-5a95-4faf-8e27-943bbdbbd6d0.png">
   
   
   


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar-client-go] wolfstudy merged pull request #774: Fix sequenceID is not equal to cause the connection to be closed incorrectly

[GitBox <gi...@apache.org>]

wolfstudy merged PR #774:
URL: https://github.com/apache/pulsar-client-go/pull/774


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org