You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/02/21 03:43:47 UTC

[GitHub] [pulsar-client-go] WinChua opened a new pull request #732: [Issue 731] Prevent sent pendingItem from being resend again after the reconnection of producer

WinChua opened a new pull request #732:
URL: https://github.com/apache/pulsar-client-go/pull/732


   Fixes #731
   
   
   ### Motivation
   
   As the #731 has show, some msg maybe sent after the reconnection of the producer, no mater the msg has been sent or not, which will cause that the same msg will be sent and consumed mulit time at the application view.
   
   ### Modifications
   
   A sent flag was added to [pendingItem](https://github.com/WinChua/pulsar-client-go/blob/42af6818c03cf6803289cdc5706eea09d82ec95f/pulsar/producer_partition.go#L520) to indicated that the corresponding buffer has been sent successfully.
   And in the resend logic the sent item will not be sent again.
   
   
   


-- 
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